spring-messaging/org.springframework.messaging.rsocket/dataWithType

dataWithType

inline fun <T : Any> RSocketRequester.RequestSpec.dataWithType(producer: Any): RSocketRequester.RetrieveSpec
Content copied to clipboard

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.

Author

Sebastien Deleuze

Since

5.2

Parameters

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


inline fun <T : Any> RSocketRequester.RequestSpec.dataWithType(publisher: Publisher<T>): RSocketRequester.RetrieveSpec
Content copied to clipboard

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.

Author

Sebastien Deleuze

Since

5.2

Parameters

publisher

the source of payload data value(s)

T

the type of values to be produced


inline fun <T : Any> RSocketRequester.RequestSpec.dataWithType(flow: Flow<T>): RSocketRequester.RetrieveSpec
Content copied to clipboard

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.

Author

Sebastien Deleuze

Since

5.2

Parameters

flow

the Flow to write to the request

T

the source of payload data value(s)