Reactor Kotlin Extensions

To use the stable release in a Maven project, add the following dependency to your pom.xml using Maven Central.

<dependency>
    <groupId>io.projectreactor.kotlin</groupId>
    <artifactId>reactor-kotlin-extensions</artifactId>
    <version>1.3.2</version>
</dependency>

You can add Reactor Kotlin Extensions to your project using Gradle or Maven. Stable releases are available via Maven Central. Snapshot versions can be obtained from the Spring repositories.

    repositories {
        mavenCentral()
    }

    dependencies {
        implementation "io.projectreactor.kotlin:reactor-kotlin-extensions:1.3.2"
    }

Use .toFlux() to convert standard Kotlin/Java collections (like IntArray) into a Reactor Flux. Note that certain operations like .sum() may require reactor-extra, and testing utilities like .test() require reactor-test.

intArrayOf(2_000_000_000, 200_000_000) //sum overflows an Int
    .toFlux()
    .sum()
    .test()
    .expectNext(2_200_000_000)
    .verifyComplete()

The whenComplete extension function allows you to coordinate the completion of two separate Mono instances. It returns a Mono that completes only when both input Monos have completed.

whenComplete("foo1".toMono(), "foo2".toMono())
    .test()
    .verifyComplete()

Reactor Kotlin Extensions provides support for Kotlin's destructuring declarations, allowing you to unpack Tuples directly into variables.

val (t1, t2, t3) = Tuples.of(O1, O2, O3)
assertEquals(t1, O1)
assertEquals(t2, O2)
assertEquals(t3, O3)