Top Description Constructors Methods

io.rsocket.plugins

public Class InitializingInterceptorRegistry

Class Inheritance

extends InterceptorRegistry

java.lang.Object
io.rsocket.plugins.InterceptorRegistry
io.rsocket.plugins.InitializingInterceptorRegistry

Imports

io.rsocket.DuplexConnection, .RSocket, .SocketAcceptor, java.util.stream.Collectors, .Stream, reactor.util.annotation.Nullable

Extends InterceptorRegistry with methods for building a chain of registered interceptors. This is not intended for direct use by applications.

Constructor Summary

Access	Constructor and Description
public	InitializingInterceptorRegistry()

Method Summary

Modifier and Type	Method and Description
public DuplexConnection	initConnection(DuplexConnectionInterceptor.Type type, DuplexConnection connection)
public RSocket	initRequester(RSocket rsocket)
public RequestInterceptor	initRequesterRequestInterceptor(RSocket rSocketRequester)
public RSocket	initResponder(RSocket rsocket)
public RequestInterceptor	initResponderRequestInterceptor(RSocket rSocketResponder, RequestInterceptor... perConnectionInterceptors)
public SocketAcceptor	initSocketAcceptor(SocketAcceptor acceptor)

Inherited from io.rsocket.plugins.InterceptorRegistry:: forConnection forConnection forRequester forRequester forRequestsInRequester forRequestsInResponder forResponder forResponder forSocketAcceptor forSocketAcceptor getConnectionInterceptors getRequesterInterceptors getRequestInterceptorsForRequester getRequestInterceptorsForResponder getResponderInterceptors getSocketAcceptorInterceptors

Constructor Detail

InitializingInterceptorRegistry	back to summary
public InitializingInterceptorRegistry()

Method Detail

initConnection	back to summary
public DuplexConnection initConnection(DuplexConnectionInterceptor.Type type, DuplexConnection connection)

initRequester	back to summary
public RSocket initRequester(RSocket rsocket)

initRequesterRequestInterceptor	back to summary
public RequestInterceptor initRequesterRequestInterceptor(RSocket rSocketRequester) Annotations @Nullable

initResponder	back to summary
public RSocket initResponder(RSocket rsocket)

initResponderRequestInterceptor	back to summary
public RequestInterceptor initResponderRequestInterceptor(RSocket rSocketResponder, RequestInterceptor... perConnectionInterceptors) Annotations @Nullable

initSocketAcceptor	back to summary
public SocketAcceptor initSocketAcceptor(SocketAcceptor acceptor)