Extensions for org.reactivestreams.Publisher
Transforms the given reactive Publisher into Flow. Use buffer operator on the resulting flow to specify the size of the backpressure. More precisely, it specifies the value of the subscription’s request. buffer default capacity is used by default. |
|
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. |
|
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. |
|
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. |
|
Awaits for the first value from the given observable or |
|
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. |
|
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. |
|
Awaits for the single value from the given publisher or the default value if none is emitted without blocking a thread and returns the resulting value or throws the corresponding exception if this publisher had produced error. |
|
Awaits for the single value from the given publisher 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 publisher had produced error. |
|
Awaits for the single value from the given publisher or |
|
Subscribes to this Publisher and performs the specified action for each received element. Cancels subscription if any exception happens during collect. |
|
fun <T> Publisher<T>. Subscribes to this Publisher and returns a channel to receive elements emitted by it. The resulting channel shall be cancelled to unsubscribe from this publisher. |