rsocket-core 1.1.4 · io.rsocket.plugins.InterceptorRegistry

Modifier and Type	Field and Description
private List<DuplexConnectionInterceptor>	connectionInterceptors
private List<Function<RSocket, ? extends RequestInterceptor>>	requesterRequestInterceptors
private List<RSocketInterceptor>	requesterRSocketInterceptors
private List<Function<RSocket, ? extends RequestInterceptor>>	responderRequestInterceptors
private List<RSocketInterceptor>	responderRSocketInterceptors
private List<SocketAcceptorInterceptor>	socketAcceptorInterceptors

Modifier and Type

Field and Description

private List<DuplexConnectionInterceptor>

connectionInterceptors

private List<Function<RSocket, ? extends RequestInterceptor>>

requesterRequestInterceptors

private List<RSocketInterceptor>

requesterRSocketInterceptors

private List<Function<RSocket, ? extends RequestInterceptor>>

responderRequestInterceptors

private List<RSocketInterceptor>

responderRSocketInterceptors

private List<SocketAcceptorInterceptor>

socketAcceptorInterceptors

Access	Constructor and Description
public	InterceptorRegistry()

Access

Constructor and Description

public

InterceptorRegistry()

Modifier and Type	Method and Description
public InterceptorRegistry	forConnection(DuplexConnectionInterceptor interceptor) Add a `DuplexConnectionInterceptor`.
public InterceptorRegistry	forConnection(Consumer<List<DuplexConnectionInterceptor>> consumer) Variant of `forConnection(DuplexConnectionInterceptor)` with access to the list of existing registrations.
public InterceptorRegistry	forRequester(RSocketInterceptor interceptor) Add an `RSocketInterceptor` that will decorate the RSocket used for performing requests.
public InterceptorRegistry	forRequester(Consumer<List<RSocketInterceptor>> consumer) Variant of `forRequester(RSocketInterceptor)` with access to the list of existing registrations.
public InterceptorRegistry	forRequestsInRequester(Function<RSocket, ? extends RequestInterceptor> a function which accepts an `RSocket` and returns a new `RequestInterceptor` interceptor) Add an `RequestInterceptor` that will hook into Requester RSocket requests' phases.
public InterceptorRegistry	forRequestsInResponder(Function<RSocket, ? extends RequestInterceptor> a function which accepts an `RSocket` and returns a new `RequestInterceptor` interceptor) Add an `RequestInterceptor` that will hook into Requester RSocket requests' phases.
public InterceptorRegistry	forResponder(RSocketInterceptor interceptor) Add an `RSocketInterceptor` that will decorate the RSocket used for resonding to requests.
public InterceptorRegistry	forResponder(Consumer<List<RSocketInterceptor>> consumer) Variant of `forResponder(RSocketInterceptor)` with access to the list of existing registrations.
public InterceptorRegistry	forSocketAcceptor(SocketAcceptorInterceptor interceptor) Add a `SocketAcceptorInterceptor` that will intercept the accepting of new connections.
public InterceptorRegistry	forSocketAcceptor(Consumer<List<SocketAcceptorInterceptor>> consumer) Variant of `forSocketAcceptor(SocketAcceptorInterceptor)` with access to the list of existing registrations.
pack-priv List<DuplexConnectionInterceptor>	getConnectionInterceptors()
pack-priv List<RSocketInterceptor>	getRequesterInterceptors()
pack-priv List<Function<RSocket, ? extends RequestInterceptor>>	getRequestInterceptorsForRequester()
pack-priv List<Function<RSocket, ? extends RequestInterceptor>>	getRequestInterceptorsForResponder()
pack-priv List<RSocketInterceptor>	getResponderInterceptors()
pack-priv List<SocketAcceptorInterceptor>	getSocketAcceptorInterceptors()

Modifier and Type

Method and Description

public InterceptorRegistry

forConnection(DuplexConnectionInterceptor interceptor)

Add a DuplexConnectionInterceptor.

public InterceptorRegistry

forConnection(Consumer<List<DuplexConnectionInterceptor>> consumer)

Variant of forConnection(DuplexConnectionInterceptor) with access to the list of existing registrations.

public InterceptorRegistry

forRequester(RSocketInterceptor interceptor)

Add an RSocketInterceptor that will decorate the RSocket used for performing requests.

public InterceptorRegistry

forRequester(Consumer<List<RSocketInterceptor>> consumer)

Variant of forRequester(RSocketInterceptor) with access to the list of existing registrations.

public InterceptorRegistry

forRequestsInRequester(Function<RSocket, ? extends RequestInterceptor>

a function which accepts an RSocket and returns a new RequestInterceptor

interceptor)

Add an RequestInterceptor that will hook into Requester RSocket requests' phases.

public InterceptorRegistry

forRequestsInResponder(Function<RSocket, ? extends RequestInterceptor>

a function which accepts an RSocket and returns a new RequestInterceptor

interceptor)

Add an RequestInterceptor that will hook into Requester RSocket requests' phases.

public InterceptorRegistry

forResponder(RSocketInterceptor interceptor)

Add an RSocketInterceptor that will decorate the RSocket used for resonding to requests.

public InterceptorRegistry

forResponder(Consumer<List<RSocketInterceptor>> consumer)

Variant of forResponder(RSocketInterceptor) with access to the list of existing registrations.

public InterceptorRegistry

forSocketAcceptor(SocketAcceptorInterceptor interceptor)

Add a SocketAcceptorInterceptor that will intercept the accepting of new connections.

public InterceptorRegistry

forSocketAcceptor(Consumer<List<SocketAcceptorInterceptor>> consumer)

Variant of forSocketAcceptor(SocketAcceptorInterceptor) with access to the list of existing registrations.

pack-priv List<DuplexConnectionInterceptor>

getConnectionInterceptors()

pack-priv List<RSocketInterceptor>

getRequesterInterceptors()

pack-priv List<Function<RSocket, ? extends RequestInterceptor>>

getRequestInterceptorsForRequester()

pack-priv List<Function<RSocket, ? extends RequestInterceptor>>

getRequestInterceptorsForResponder()

pack-priv List<RSocketInterceptor>

getResponderInterceptors()

pack-priv List<SocketAcceptorInterceptor>

getSocketAcceptorInterceptors()

Field Detail

connectionInterceptors	back to summary
private List<DuplexConnectionInterceptor> connectionInterceptors

connectionInterceptors

back to summary

private List<DuplexConnectionInterceptor> connectionInterceptors

requesterRequestInterceptors	back to summary
private List<Function<RSocket, ? extends RequestInterceptor>> requesterRequestInterceptors

requesterRequestInterceptors

back to summary

private List<Function<RSocket, ? extends RequestInterceptor>> requesterRequestInterceptors

requesterRSocketInterceptors	back to summary
private List<RSocketInterceptor> requesterRSocketInterceptors

requesterRSocketInterceptors

back to summary

private List<RSocketInterceptor> requesterRSocketInterceptors

responderRequestInterceptors	back to summary
private List<Function<RSocket, ? extends RequestInterceptor>> responderRequestInterceptors

responderRequestInterceptors

back to summary

private List<Function<RSocket, ? extends RequestInterceptor>> responderRequestInterceptors

responderRSocketInterceptors	back to summary
private List<RSocketInterceptor> responderRSocketInterceptors

responderRSocketInterceptors

back to summary

private List<RSocketInterceptor> responderRSocketInterceptors

socketAcceptorInterceptors	back to summary
private List<SocketAcceptorInterceptor> socketAcceptorInterceptors

socketAcceptorInterceptors

back to summary

private List<SocketAcceptorInterceptor> socketAcceptorInterceptors

InterceptorRegistry	back to summary
public InterceptorRegistry()

InterceptorRegistry

back to summary

public InterceptorRegistry()

Method Detail

forConnection	back to summary
public InterceptorRegistry forConnection(DuplexConnectionInterceptor interceptor) Add a `DuplexConnectionInterceptor`.

forConnection	back to summary
public InterceptorRegistry forConnection(Consumer<List<DuplexConnectionInterceptor>> consumer) Variant of `forConnection(DuplexConnectionInterceptor)` with access to the list of existing registrations.

forRequester	back to summary
public InterceptorRegistry forRequester(RSocketInterceptor interceptor) Add an `RSocketInterceptor` that will decorate the RSocket used for performing requests.

forRequester	back to summary
public InterceptorRegistry forRequester(Consumer<List<RSocketInterceptor>> consumer) Variant of `forRequester(RSocketInterceptor)` with access to the list of existing registrations.

forRequestsInRequester back to summary

forRequestsInRequester	back to summary
public InterceptorRegistry forRequestsInRequester(Function<RSocket, ? extends RequestInterceptor> interceptor) Add an `RequestInterceptor` that will hook into Requester RSocket requests' phases. Parameters interceptor:Function<RSocket, ? extends RequestInterceptor> a function which accepts an `RSocket` and returns a new `RequestInterceptor` Since 1.1

public InterceptorRegistry forRequestsInRequester(Function<RSocket, ? extends RequestInterceptor> interceptor)

Add an RequestInterceptor that will hook into Requester RSocket requests' phases.

Parameters

interceptor:Function<RSocket, ? extends RequestInterceptor>: a function which accepts an RSocket and returns a new RequestInterceptor

Since

1.1

forRequestsInResponder back to summary

forRequestsInResponder	back to summary
public InterceptorRegistry forRequestsInResponder(Function<RSocket, ? extends RequestInterceptor> interceptor) Add an `RequestInterceptor` that will hook into Requester RSocket requests' phases. Parameters interceptor:Function<RSocket, ? extends RequestInterceptor> a function which accepts an `RSocket` and returns a new `RequestInterceptor` Since 1.1

public InterceptorRegistry forRequestsInResponder(Function<RSocket, ? extends RequestInterceptor> interceptor)

Add an RequestInterceptor that will hook into Requester RSocket requests' phases.

Parameters

interceptor:Function<RSocket, ? extends RequestInterceptor>: a function which accepts an RSocket and returns a new RequestInterceptor

Since

1.1

forResponder	back to summary
public InterceptorRegistry forResponder(RSocketInterceptor interceptor) Add an `RSocketInterceptor` that will decorate the RSocket used for resonding to requests.

forResponder	back to summary
public InterceptorRegistry forResponder(Consumer<List<RSocketInterceptor>> consumer) Variant of `forResponder(RSocketInterceptor)` with access to the list of existing registrations.

forSocketAcceptor	back to summary
public InterceptorRegistry forSocketAcceptor(SocketAcceptorInterceptor interceptor) Add a `SocketAcceptorInterceptor` that will intercept the accepting of new connections.

forSocketAcceptor	back to summary
public InterceptorRegistry forSocketAcceptor(Consumer<List<SocketAcceptorInterceptor>> consumer) Variant of `forSocketAcceptor(SocketAcceptorInterceptor)` with access to the list of existing registrations.

getConnectionInterceptors	back to summary
pack-priv List<DuplexConnectionInterceptor> getConnectionInterceptors()

getRequesterInterceptors	back to summary
pack-priv List<RSocketInterceptor> getRequesterInterceptors()

getRequestInterceptorsForRequester	back to summary
pack-priv List<Function<RSocket, ? extends RequestInterceptor>> getRequestInterceptorsForRequester()

getRequestInterceptorsForResponder	back to summary
pack-priv List<Function<RSocket, ? extends RequestInterceptor>> getRequestInterceptorsForResponder()

getResponderInterceptors	back to summary
pack-priv List<RSocketInterceptor> getResponderInterceptors()

getSocketAcceptorInterceptors	back to summary
pack-priv List<SocketAcceptorInterceptor> getSocketAcceptorInterceptors()

public Class InterceptorRegistry

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail