spring-framework / org.springframework.messaging.rsocket / retrieveFlux

retrieveFlux

fun <reified T : Any> RetrieveSpec.retrieveFlux(): Flux<T>

Extension for RSocketRequester.RetrieveSpec.retrieveFlux providing a retrieveFlux<Foo>() variant leveraging Kotlin reified type parameters. This extension is not subject to type erasure and retains actual generic type arguments.

Author
Sebastien Deleuze

Since
5.2