Top Description Interfaces Classes
[default module]

Package io.rsocket.plugins

Annotations
@NonNullApi
Imports
reactor.util.annotation.NonNullApi
Contracts for interception of transports, connections, and requests in in RSocket Java.

Interface Summary

Modifier and TypeInterface and Description
public interface
DuplexConnectionInterceptor

Contract to decorate a DuplexConnection and intercept the sending and receiving of RSocket frames at the transport level.

public interface
RequestInterceptor

Class used to track the RSocket requests lifecycles.

public interface
RSocketInterceptor

Contract to decorate an RSocket, providing a way to intercept interactions.

public interface
SocketAcceptorInterceptor

Contract to decorate a SocketAcceptor, providing access to connection setup information and the ability to also decorate the sockets for requesting and responding.

Class Summary

Modifier and TypeClass and Description
pack-priv class
CompositeRequestInterceptor

public class
InitializingInterceptorRegistry

Extends InterceptorRegistry with methods for building a chain of registered interceptors.

public class
InterceptorRegistry

Provides support for registering interceptors at the following levels:

public class
LimitRateInterceptor

Interceptor that adds Flux#limitRate(int, int) to publishers of outbound streams that breaks down or aggregates demand values from the remote end (i.e. REQUEST_N frames) into batches of a uniform size.