fun <reified T : Any> RequestSpec.dataWithType(producer: Any): RetrieveSpec
Extension for RSocketRequester.RequestSpec.data providing a dataWithType<Foo>(Any)
variant leveraging Kotlin reified type parameters. This extension is not subject to type
erasure and retains actual generic type arguments.
producer - the source of payload data value(s). This must be a
Publisher or another producer adaptable to a
Publisher via org.springframework.core.ReactiveAdapterRegistry
T - the type of values to be produced
Author
Sebastien Deleuze
Since
5.2
fun <reified T : Any> RequestSpec.dataWithType(publisher: Publisher<T>): RetrieveSpec
Extension for RSocketRequester.RequestSpec.data providing a dataWithType(Publisher<T>)
variant leveraging Kotlin reified type parameters. This extension is not subject to type
erasure and retains actual generic type arguments.
publisher - the source of payload data value(s)
T - the type of values to be produced
Author
Sebastien Deleuze
Since
5.2
fun <reified T : Any> RequestSpec.dataWithType(flow: Flow<T>): RetrieveSpec
Extension for RSocketRequester.RequestSpec.data providing a dataWithType(Flow<T>)
variant leveraging Kotlin reified type parameters. This extension is not subject to type
erasure and retains actual generic type arguments.
flow - the Flow to write to the request
T - the source of payload data value(s)
Author
Sebastien Deleuze
Since
5.2