reactor-kotlin-extensions/reactor.kotlin.core.publisher/toFlux

toFlux

fun <T : Any> Publisher<T>.toFlux(): Flux<T>

Extension to convert any Publisher of T to a Flux.

Note this extension doesn't make much sense on a Flux but it won't be converted so it doesn't hurt.

Author

Simon Baslé

Since

3.1.1

fun <T : Any> Iterator<T>.toFlux(): Flux<T>

Extension for transforming an Iterator to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun <T : Any> Iterable<T>.toFlux(): Flux<T>

Extension for transforming an Iterable to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun <T : Any> Sequence<T>.toFlux(): Flux<T>

Extension for transforming a Sequence to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun <T : Any> Stream<T>.toFlux(): Flux<T>

Extension for transforming a Stream to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun BooleanArray.toFlux(): Flux<Boolean>

Extension for transforming a BooleanArray to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun ByteArray.toFlux(): Flux<Byte>

Extension for transforming a ByteArray to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun ShortArray.toFlux(): Flux<Short>

Extension for transforming a ShortArray to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun IntArray.toFlux(): Flux<Int>

Extension for transforming a IntArray to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun LongArray.toFlux(): Flux<Long>

Extension for transforming a LongArray to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun FloatArray.toFlux(): Flux<Float>

Extension for transforming a FloatArray to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun DoubleArray.toFlux(): Flux<Double>

Extension for transforming a DoubleArray to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun <T> Array<out T>.toFlux(): Flux<T>

Extension for transforming an Array to a Flux.

Author

Sebastien Deleuze

Since

3.1

fun <T> Throwable.toFlux(): Flux<T>

Extension for transforming an exception to a Flux that completes with the specified error.

Author

Sebastien Deleuze

Since

3.1