[default module]

Package io.rsocket.internal

Annotations

Imports

reactor.util.annotation.NonNullApi

Internal package and must not be used outside this project. There are no guarantees for API compatibility.

Class Summary

Modifier and Type	Class and Description
public abstract class	BaseDuplexConnection
public class	UnboundedProcessor A Processor implementation that takes a custom queue and allows only a single subscriber.