spring-framework / org.springframework.messaging.rsocket

Package org.springframework.messaging.rsocket

Functions

connectAndAwait

suspend fun Builder.connectAndAwait(transport: ClientTransport): RSocketRequester

Coroutines variant of RSocketRequester.Builder.connect.

connectTcpAndAwait

suspend fun Builder.connectTcpAndAwait(host: String, port: Int): RSocketRequester

Coroutines variant of RSocketRequester.Builder.connectTcp.

connectWebSocketAndAwait

suspend fun Builder.connectWebSocketAndAwait(uri: URI): RSocketRequester

Coroutines variant of RSocketRequester.Builder.connectWebSocket.

dataWithType

fun <T : Any> RequestSpec.dataWithType(producer: Any): ResponseSpec

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.

fun <T : Any> RequestSpec.dataWithType(publisher: Publisher<T>): ResponseSpec

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.

fun <T : Any> RequestSpec.dataWithType(flow: Flow<T>): ResponseSpec

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.

retrieveAndAwait

suspend fun <T : Any> ResponseSpec.retrieveAndAwait(): T

Coroutines variant of RSocketRequester.ResponseSpec.retrieveMono.

retrieveFlow

fun <T : Any> ResponseSpec.retrieveFlow(): Flow<T>

Coroutines variant of RSocketRequester.ResponseSpec.retrieveFlux.

retrieveFlux

fun <T : Any> ResponseSpec.retrieveFlux(): Flux<T>

Extension for RSocketRequester.ResponseSpec.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.

retrieveMono

fun <T : Any> ResponseSpec.retrieveMono(): Mono<T>

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

sendAndAwait

suspend fun ResponseSpec.sendAndAwait(): Unit

Coroutines variant of RSocketRequester.ResponseSpec.send.