kotlin-flow-extensions

alltypes

@FlowPreview class BehaviorSubject<T> : AbstractFlow<T>, SubjectAPI<T>

BehaviorSubject()
BehaviorSubject(initialValue: T)
suspend fun collectSafely(collector: FlowCollector<T>): Unit
fun collectorCount(): Int
suspend fun complete(): Unit
suspend fun emit(value: T): Unit
suspend fun emitError(ex: Throwable): Unit
fun hasCollectors(): Boolean

@FlowPreview class PublishSubject<T> : AbstractFlow<T>, SubjectAPI<T>

PublishSubject()
@FlowPreview suspend fun collectSafely(collector: FlowCollector<T>): Unit
fun collectorCount(): Int
suspend fun complete(): Unit
suspend fun emit(value: T): Unit
suspend fun emitError(ex: Throwable): Unit
fun hasCollectors(): Boolean

@FlowPreview class ReplaySubject<T> : AbstractFlow<T>, SubjectAPI<T>

ReplaySubject()
ReplaySubject(maxSize: Int)
ReplaySubject(maxTime: Long, unit: TimeUnit)
ReplaySubject(maxSize: Int, maxTime: Long, unit: TimeUnit)
ReplaySubject(maxSize: Int, maxTime: Long, unit: TimeUnit, timeSource: (TimeUnit) -> Long)
@FlowPreview suspend fun collectSafely(collector: FlowCollector<T>): Unit
fun collectorCount(): Int
suspend fun complete(): Unit
suspend fun emit(value: T): Unit
suspend fun emitError(ex: Throwable): Unit
fun hasCollectors(): Boolean

open class Resumable : AtomicReference<Continuation<Any>>

Resumable()
suspend fun await(): Unit
fun resume(): Unit

interface SubjectAPI<T> : FlowCollector<T>

abstract fun collectorCount(): Int
abstract suspend fun complete(): Unit
abstract suspend fun emitError(ex: Throwable): Unit
abstract fun hasCollectors(): Boolean

package hu.akarnokd.kotlin.flow

@FlowPreview class BehaviorSubject<T> : AbstractFlow<T>, SubjectAPI<T>

BehaviorSubject()
BehaviorSubject(initialValue: T)
suspend fun collectSafely(collector: FlowCollector<T>): Unit
fun collectorCount(): Int
suspend fun complete(): Unit
suspend fun emit(value: T): Unit
suspend fun emitError(ex: Throwable): Unit
fun hasCollectors(): Boolean

@FlowPreview class PublishSubject<T> : AbstractFlow<T>, SubjectAPI<T>

PublishSubject()
@FlowPreview suspend fun collectSafely(collector: FlowCollector<T>): Unit
fun collectorCount(): Int
suspend fun complete(): Unit
suspend fun emit(value: T): Unit
suspend fun emitError(ex: Throwable): Unit
fun hasCollectors(): Boolean

@FlowPreview class ReplaySubject<T> : AbstractFlow<T>, SubjectAPI<T>

ReplaySubject()
ReplaySubject(maxSize: Int)
ReplaySubject(maxTime: Long, unit: TimeUnit)
ReplaySubject(maxSize: Int, maxTime: Long, unit: TimeUnit)
ReplaySubject(maxSize: Int, maxTime: Long, unit: TimeUnit, timeSource: (TimeUnit) -> Long)
@FlowPreview suspend fun collectSafely(collector: FlowCollector<T>): Unit
fun collectorCount(): Int
suspend fun complete(): Unit
suspend fun emit(value: T): Unit
suspend fun emitError(ex: Throwable): Unit
fun hasCollectors(): Boolean

open class Resumable : AtomicReference<Continuation<Any>>

Resumable()
suspend fun await(): Unit
fun resume(): Unit

interface SubjectAPI<T> : FlowCollector<T>

abstract fun collectorCount(): Int
abstract suspend fun complete(): Unit
abstract suspend fun emitError(ex: Throwable): Unit
abstract fun hasCollectors(): Boolean