public abstract class AbstractRSocket extends Object implements RSocket
RSocket. All request handling methods emit UnsupportedOperationException and hence must be overridden to provide a valid implementation.Disposable.Composite, Disposable.Swap| Constructor and Description |
|---|
AbstractRSocket() |
| Modifier and Type | Method and Description |
|---|---|
void |
dispose() |
Mono<Void> |
fireAndForget(Payload payload)
Fire and Forget interaction model of
RSocket. |
boolean |
isDisposed() |
Mono<Void> |
metadataPush(Payload payload)
Metadata-Push interaction model of
RSocket. |
Mono<Void> |
onClose()
Returns a
Publisher that completes when this RSocket is closed. |
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. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitavailabilitypublic Mono<Void> fireAndForget(Payload payload)
RSocketRSocket.fireAndForget in interface RSocketpayload - Request payload.Publisher that completes when the passed payload is successfully
handled, otherwise errors.public Mono<Payload> requestResponse(Payload payload)
RSocketRSocket.requestResponse in interface RSocketpayload - Request payload.Publisher containing at most a single Payload representing the
response.public Flux<Payload> requestStream(Payload payload)
RSocketRSocket.requestStream in interface RSocketpayload - Request payload.Publisher containing the stream of Payloads representing the response.public Flux<Payload> requestChannel(org.reactivestreams.Publisher<Payload> payloads)
RSocketRSocket.requestChannel in interface RSocketpayloads - Stream of request payloads.public Mono<Void> metadataPush(Payload payload)
RSocketRSocket.metadataPush in interface RSocketpayload - Request payloads.Publisher that completes when the passed payload is successfully
handled, otherwise errors.public void dispose()
dispose in interface Disposablepublic boolean isDisposed()
isDisposed in interface Disposablepublic Mono<Void> onClose()
CloseablePublisher that completes when this RSocket is closed. A RSocket can be closed by explicitly calling Disposable.dispose() or when the underlying
transport connection is closed.