Package org.springframework.messaging.rsocket
Functions
connectAndAwait
Link copied to clipboard
suspend fun RSocketRequester.Builder.connectAndAwait(transport: ClientTransport): RSocketRequester
Content copied to clipboard
Coroutines variant of RSocketRequester.Builder.connect.
connectTcpAndAwait
Link copied to clipboard
suspend fun RSocketRequester.Builder.connectTcpAndAwait(host: String, port: Int): RSocketRequester
Content copied to clipboard
Coroutines variant of RSocketRequester.Builder.connectTcp.
connectWebSocketAndAwait
Link copied to clipboard
suspend fun RSocketRequester.Builder.connectWebSocketAndAwait(uri: URI): RSocketRequester
Content copied to clipboard
Coroutines variant of RSocketRequester.Builder.connectWebSocket.
dataWithType
Link copied to clipboard
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.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.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.metadataToExtract
Link copied to clipboard
inline fun <T : Any> MetadataExtractorRegistry.metadataToExtract(mimeType: MimeType, noinline mapper: (T, MutableMap<String, Any>) -> Unit)
Content copied to clipboard
Extension for MetadataExtractorRegistry.metadataToExtract providing a
metadataToExtract<Foo>(...) variant leveraging Kotlin reified type parameters.inline fun <T : Any> MetadataExtractorRegistry.metadataToExtract(mimeType: MimeType, name: String? = null)
Content copied to clipboard
Extension for MetadataExtractorRegistry.metadataToExtract providing a
metadataToExtract<Foo>(...) variant leveraging Kotlin reified type parameters.retrieveAndAwait
Link copied to clipboard
inline suspend fun <T : Any> RSocketRequester.RetrieveSpec.retrieveAndAwait(): T
Content copied to clipboard
Coroutines variant of RSocketRequester.RetrieveSpec.retrieveMono.
retrieveAndAwaitOrNull
Link copied to clipboard
inline suspend fun <T : Any> RSocketRequester.RetrieveSpec.retrieveAndAwaitOrNull(): T?
Content copied to clipboard
Nullable coroutines variant of RSocketRequester.RetrieveSpec.retrieveMono.
retrieveFlow
Link copied to clipboard
inline fun <T : Any> RSocketRequester.RetrieveSpec.retrieveFlow(): Flow<T>
Content copied to clipboard
Coroutines variant of RSocketRequester.RetrieveSpec.retrieveFlux.
retrieveFlux
Link copied to clipboard
inline fun <T : Any> RSocketRequester.RetrieveSpec.retrieveFlux(): Flux<T>
Content copied to clipboard
Extension for RSocketRequester.RetrieveSpec.retrieveFlux providing a
retrieveFlux<Foo>() variant leveraging Kotlin reified type parameters.retrieveMono
Link copied to clipboard
inline fun <T : Any> RSocketRequester.RetrieveSpec.retrieveMono(): Mono<T>
Content copied to clipboard
Extension for RSocketRequester.RetrieveSpec.retrieveMono providing a
retrieveMono<Foo>() variant leveraging Kotlin reified type parameters.sendAndAwait
Link copied to clipboard