reactor-core / reactor.core.publisher / ofType

ofType

inline fun <reified T : Any> Flux<*>.ofType(): Flux<T>

Extension for Flux.ofType providing a ofType<Foo>() variant.

Author
Sebastien Deleuze

Since
3.1

inline fun <reified T : Any> Mono<*>.ofType(): Mono<T>

Extension for Mono.ofType providing a ofType<Foo>() variant.

Author
Sebastien Deleuze

Since
3.1