rsocket library

Classes

Availability
Closeable
RSocket
RSocketService

Functions

fireAndForgetAcceptor(FireAndForget fireAndForget) SocketAcceptor
requestResponseAcceptor(RequestResponse requestResponse) SocketAcceptor
requestStreamAcceptor(RequestStream requestStream) SocketAcceptor

Typedefs

FireAndForget = Future<void> Function(Payload payload)
MetadataPush = Future<void> Function(Payload payload)
RequestChannel = Stream<Payload> Function(Stream<Payload> payloads)
RequestResponse = Future<Payload> Function(Payload payload)
RequestStream = Stream<Payload> Function(Payload payload)
RSocketClose = void Function()
SocketAcceptor = RSocket Function(ConnectionSetupPayload setup, RSocket sendingSocket)