Utilities for Reactive Streams.
Coroutine builders:
Name Result Scope Description kotlinx.coroutines.reactive.publishPublisher ProducerScope Cold reactive publisher that starts the coroutine on subscribe
Integration with Flow:
Name Result Description Publisher.asFlowFlow Converts the given publisher to a flow Flow.asPublisher Publisher Converts the given flow to a TCK-compliant publisher
If these adapters are used along with kotlinx-coroutines-reactor in the classpath, then Reactor's Context is properly propagated as coroutine context element (ReactorContext) and vice versa.
Suspending extension functions and suspending iteration:
Name Description Publisher.awaitFirst Returns the first value from the given publisher Publisher.awaitFirstOrDefault Returns the first value from the given publisher or default Publisher.awaitFirstOrElse Returns the first value from the given publisher or default from a function Publisher.awaitFirstOrNull Returns the first value from the given publisher or null Publisher.awaitLast Returns the last value from the given publisher Publisher.awaitSingle Returns the single value from the given publisherRetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4