Skip to content

Latest commit

 

History

History
 
 

kotlinx-coroutines-reactive

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
api
api
 
 
src
src
 
 
test
test
 
 
README.md
README.md
 
 
build.gradle.kts
build.gradle.kts
 
 
package.list
package.list
 
 

README.md

Module kotlinx-coroutines-reactive

Utilities for Reactive Streams.

Coroutine builders:

Name Result Scope Description
kotlinx.coroutines.reactive.publish Publisher ProducerScope Cold reactive publisher that starts the coroutine on subscribe

Integration with Flow:

Name Result Description
Publisher.asFlow Flow 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 publisher

Package kotlinx.coroutines.reactive

Utilities for Reactive Streams.