kotlinx-coroutines-reactive / kotlinx.coroutines.experimental.reactive / org.reactivestreams.Publisher

Extensions for org.reactivestreams.Publisher

awaitFirst
suspend fun <T> Publisher<T>.awaitFirst(): T

Awaits for the first value from the given publisher without blocking a thread and returns the resulting value or throws the corresponding exception if this publisher had produced error.

awaitFirstOrDefault
suspend fun <T> Publisher<T>.awaitFirstOrDefault(
    default: T
): T

Awaits for the first value from the given observable or the default value if none is emitted without blocking a thread and returns the resulting value or throws the corresponding exception if this observable had produced error.

awaitFirstOrElse
suspend fun <T> Publisher<T>.awaitFirstOrElse(
    defaultValue: () -> T
): T

Awaits for the first value from the given observable or call defaultValue to get a value if none is emitted without blocking a thread and returns the resulting value or throws the corresponding exception if this observable had produced error.

awaitFirstOrNull
suspend fun <T> Publisher<T>.awaitFirstOrNull(): T?

Awaits for the first value from the given observable or null value if none is emitted without blocking a thread and returns the resulting value or throws the corresponding exception if this observable had produced error.

awaitLast
suspend fun <T> Publisher<T>.awaitLast(): T

Awaits for the last value from the given publisher without blocking a thread and returns the resulting value or throws the corresponding exception if this publisher had produced error.

awaitSingle
suspend fun <T> Publisher<T>.awaitSingle(): T

Awaits for the single value from the given publisher without blocking a thread and returns the resulting value or throws the corresponding exception if this publisher had produced error.

consumeEach
suspend fun <T> Publisher<T>.consumeEach(
    action: (T) -> Unit
): Unit

Subscribes to this Publisher and performs the specified action for each received element.

iterator
operator fun <T> Publisher<T>.iterator(): ChannelIterator<T>

Subscribes to this Publisher and returns an iterator to receive elements emitted by it.

openSubscription
fun <T> Publisher<T>.openSubscription(
    request: Int = 0
): SubscriptionReceiveChannel<T>

Subscribes to this Publisher and returns a channel to receive elements emitted by it. The resulting channel shall be closed to unsubscribe from this publisher.