You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
hmz007
6d24f2138b
|
3 years ago | |
|---|---|---|
| .. | ||
| api | 3 years ago | |
| resources/META-INF/services | 3 years ago | |
| src | 3 years ago | |
| test | 3 years ago | |
| README.md | 3 years ago | |
| build.gradle.kts | 3 years ago | |
| package.list | 3 years ago | |
README.md
Module kotlinx-coroutines-reactor
Utilities for Reactor.
Coroutine builders:
| Name | Result | Scope | Description |
|---|---|---|---|
| mono | Mono |
CoroutineScope | A cold Mono that starts the coroutine on subscription |
| flux | Flux |
CoroutineScope | A cold Flux that starts the coroutine on subscription |
Note that Mono and Flux are subclasses of Reactive Streams'
Publisher and extensions for it are covered by the
kotlinx-coroutines-reactive module.
Integration with Flow:
| Name | Result | Description |
|---|---|---|
| Flow.asFlux | Flux |
Converts the given flow to a TCK-compliant Flux. |
This adapter is integrated with Reactor's Context and coroutines' ReactorContext.
Conversion functions:
| Name | Description |
|---|---|
| Job.asMono | Converts a job to a hot Mono |
| Deferred.asMono | Converts a deferred value to a hot Mono |
| ReceiveChannel.asFlux | Converts a streaming channel to a hot Flux |
| Scheduler.asCoroutineDispatcher | Converts a scheduler to a CoroutineDispatcher |
Package kotlinx.coroutines.reactor
Utilities for Reactor.