Top Description Fields Constructors Methods
io.rsocket.util

public Class RSocketProxy

extends Object
implements RSocket
Class Inheritance
All Implemented Interfaces
io.rsocket.RSocket, io.rsocket.Closeable, reactor.core.Disposable, io.rsocket.Availability
Known Direct Subclasses
io.rsocket.loadbalance.WeightedStatsRSocketProxy, io.rsocket.plugins.LimitRateInterceptor.ResponderProxy, io.rsocket.plugins.LimitRateInterceptor.RequesterProxy
Imports
io.rsocket.Payload, .RSocket, org.reactivestreams.Publisher, reactor.core.publisher.Flux, .Mono
Wrapper/Proxy for a RSocket. This is useful when we want to override a specific method.

Field Summary

Modifier and TypeField and Description
protected final RSocket
source

Constructor Summary

AccessConstructor and Description
public
RSocketProxy(RSocket source)

Method Summary

Modifier and TypeMethod and Description
public double
availability()

Overrides default io.rsocket.RSocket.availability.

public void
dispose()

Overrides default io.rsocket.RSocket.dispose.

Cancel or dispose the underlying task or resource.
public Mono<Void>
fireAndForget(Payload
Request payload.
payload)

Overrides default io.rsocket.RSocket.fireAndForget.

Fire and Forget interaction model of RSocket.
public boolean
isDisposed()

Overrides default io.rsocket.RSocket.isDisposed.

Optionally return true when the resource or task is disposed.
public Mono<Void>
metadataPush(Payload
Request payloads.
payload)

Overrides default io.rsocket.RSocket.metadataPush.

Metadata-Push interaction model of RSocket.
public Mono<Void>
onClose()

Overrides default io.rsocket.RSocket.onClose.

Returns a Mono that terminates when the instance is terminated by any reason.
public Flux<Payload>
requestChannel(Publisher<Payload>
Stream of request payloads.
payloads)

Overrides default io.rsocket.RSocket.requestChannel.

Request-Channel interaction model of RSocket.
public Mono<Payload>
requestResponse(Payload
Request payload.
payload)

Overrides default io.rsocket.RSocket.requestResponse.

Request-Response interaction model of RSocket.
public Flux<Payload>
requestStream(Payload
Request payload.
payload)

Overrides default io.rsocket.RSocket.requestStream.

Request-Stream interaction model of RSocket.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

sourceback to summary
protected final RSocket source

Constructor Detail

RSocketProxyback to summary
public RSocketProxy(RSocket source)

Method Detail

availabilityback to summary
public double availability()

Overrides default io.rsocket.RSocket.availability.

Returns:double

Doc from io.rsocket.Availability.availability.

a positive numbers representing the availability of the entity. Higher is better, 0.0 means not available

Annotations
@Override
disposeback to summary
public void dispose()

Overrides default io.rsocket.RSocket.dispose.

Doc from reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

Annotations
@Override
fireAndForgetback to summary
public Mono<Void> fireAndForget(Payload payload)

Overrides default io.rsocket.RSocket.fireAndForget.

Doc from io.rsocket.RSocket.fireAndForget.

Fire and Forget interaction model of RSocket.

Parameters
payload:Payload

Request payload.

Returns:Mono<Void>

Publisher that completes when the passed payload is successfully handled, otherwise errors.

Annotations
@Override
isDisposedback to summary
public boolean isDisposed()

Overrides default io.rsocket.RSocket.isDisposed.

Doc from reactor.core.Disposable.isDisposed.

Optionally return true when the resource or task is disposed.

Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed.

Returns:boolean

true when there's a guarantee the resource or task is disposed.

Annotations
@Override
metadataPushback to summary
public Mono<Void> metadataPush(Payload payload)

Overrides default io.rsocket.RSocket.metadataPush.

Doc from io.rsocket.RSocket.metadataPush.

Metadata-Push interaction model of RSocket.

Parameters
payload:Payload

Request payloads.

Returns:Mono<Void>

Publisher that completes when the passed payload is successfully handled, otherwise errors.

Annotations
@Override
onCloseback to summary
public Mono<Void> onClose()

Overrides default io.rsocket.RSocket.onClose.

Doc from io.rsocket.Closeable.onClose.

Returns a Mono that terminates when the instance is terminated by any reason. Note, in case of error termination, the cause of error will be propagated as an error signal through org.reactivestreams.Subscriber#onError(Throwable). Otherwise, Subscriber#onComplete() will be called.

Returns:Mono<Void>

a Mono to track completion with success or error of the underlying resource. When the underlying resource is an `RSocket`, the Mono exposes stream 0 (i.e. connection level) errors.

Annotations
@Override
requestChannelback to summary
public Flux<Payload> requestChannel(Publisher<Payload> payloads)

Overrides default io.rsocket.RSocket.requestChannel.

Doc from io.rsocket.RSocket.requestChannel.

Request-Channel interaction model of RSocket.

Parameters
payloads:Publisher<Payload>

Stream of request payloads.

Returns:Flux<Payload>

Stream of response payloads.

Annotations
@Override
requestResponseback to summary
public Mono<Payload> requestResponse(Payload payload)

Overrides default io.rsocket.RSocket.requestResponse.

Doc from io.rsocket.RSocket.requestResponse.

Request-Response interaction model of RSocket.

Parameters
payload:Payload

Request payload.

Returns:Mono<Payload>

Publisher containing at most a single Payload representing the response.

Annotations
@Override
requestStreamback to summary
public Flux<Payload> requestStream(Payload payload)

Overrides default io.rsocket.RSocket.requestStream.

Doc from io.rsocket.RSocket.requestStream.

Request-Stream interaction model of RSocket.

Parameters
payload:Payload

Request payload.

Returns:Flux<Payload>

Publisher containing the stream of Payloads representing the response.

Annotations
@Override