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)