public interface RSocket extends Availability, Closeable
Disposable.Composite, Disposable.Swap| Modifier and Type | Method and Description |
|---|---|
default double |
availability() |
Mono<Void> |
fireAndForget(Payload payload)
Fire and Forget interaction model of
RSocket. |
Mono<Void> |
metadataPush(Payload payload)
Metadata-Push interaction model of
RSocket. |
Flux<Payload> |
requestChannel(org.reactivestreams.Publisher<Payload> payloads)
Request-Channel interaction model of
RSocket. |
Mono<Payload> |
requestResponse(Payload payload)
Request-Response interaction model of
RSocket. |
Flux<Payload> |
requestStream(Payload payload)
Request-Stream interaction model of
RSocket. |
dispose, isDisposedMono<Void> fireAndForget(Payload payload)
RSocket.payload - Request payload.Publisher that completes when the passed payload is successfully
handled, otherwise errors.Mono<Payload> requestResponse(Payload payload)
RSocket.payload - Request payload.Publisher containing at most a single Payload representing the
response.Flux<Payload> requestStream(Payload payload)
RSocket.payload - Request payload.Publisher containing the stream of Payloads representing the response.Flux<Payload> requestChannel(org.reactivestreams.Publisher<Payload> payloads)
RSocket.payloads - Stream of request payloads.Mono<Void> metadataPush(Payload payload)
RSocket.payload - Request payloads.Publisher that completes when the passed payload is successfully
handled, otherwise errors.default double availability()
availability in interface Availability