Name | Date | Size | #Lines | LOC | ||
---|---|---|---|---|---|---|
.. | - | - | ||||
api/ | H | 25-Apr-2025 | - | 71 | 60 | |
resources/META-INF/services/ | H | 25-Apr-2025 | - | 2 | 1 | |
src/ | H | 25-Apr-2025 | - | 618 | 296 | |
test/ | H | 25-Apr-2025 | - | 1,509 | 1,320 | |
README.md | H A D | 25-Apr-2025 | 3.1 KiB | 59 | 40 | |
build.gradle.kts | H A D | 25-Apr-2025 | 1.1 KiB | 47 | 35 | |
package.list | H A D | 25-Apr-2025 | 179 | 10 | 9 |
README.md
1# Module kotlinx-coroutines-reactor 2 3Utilities for [Reactor](https://projectreactor.io). 4 5Coroutine builders: 6 7| **Name** | **Result** | **Scope** | **Description** 8| --------------- | ------------| ---------------- | --------------- 9| [mono] | `Mono` | [CoroutineScope] | A cold Mono that starts the coroutine on subscription 10| [flux] | `Flux` | [CoroutineScope] | A cold Flux that starts the coroutine on subscription 11 12Note that `Mono` and `Flux` are subclasses of [Reactive Streams](https://www.reactive-streams.org)' 13`Publisher` and extensions for it are covered by the 14[kotlinx-coroutines-reactive](../kotlinx-coroutines-reactive) module. 15 16Integration with [Flow]: 17 18| **Name** | **Result** | **Description** 19| --------------- | -------------- | --------------- 20| [Flow.asFlux] | `Flux` | Converts the given flow to a TCK-compliant Flux. 21 22This adapter is integrated with Reactor's `Context` and coroutines' [ReactorContext]. 23 24Conversion functions: 25 26| **Name** | **Description** 27| -------- | --------------- 28| [Job.asMono][kotlinx.coroutines.Job.asMono] | Converts a job to a hot Mono 29| [Deferred.asMono][kotlinx.coroutines.Deferred.asMono] | Converts a deferred value to a hot Mono 30| [Scheduler.asCoroutineDispatcher][reactor.core.scheduler.Scheduler.asCoroutineDispatcher] | Converts a scheduler to a [CoroutineDispatcher] 31 32<!--- MODULE kotlinx-coroutines-core --> 33<!--- INDEX kotlinx.coroutines --> 34 35[CoroutineScope]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/-coroutine-scope/index.html 36[CoroutineDispatcher]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/-coroutine-dispatcher/index.html 37 38<!--- INDEX kotlinx.coroutines.channels --> 39<!--- INDEX kotlinx.coroutines.flow --> 40 41[Flow]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/-flow/index.html 42 43<!--- MODULE kotlinx-coroutines-reactor --> 44<!--- INDEX kotlinx.coroutines.reactor --> 45 46[mono]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/mono.html 47[flux]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/flux.html 48[Flow.asFlux]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/as-flux.html 49[ReactorContext]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/-reactor-context/index.html 50[kotlinx.coroutines.Job.asMono]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/as-mono.html 51[kotlinx.coroutines.Deferred.asMono]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/as-mono.html 52[reactor.core.scheduler.Scheduler.asCoroutineDispatcher]: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.coroutines.reactor/as-coroutine-dispatcher.html 53 54<!--- END --> 55 56# Package kotlinx.coroutines.reactor 57 58Utilities for [Reactor](https://projectreactor.io). 59