shelf library

Classes

AuthMetadata
Availability
CancelFrame
Closeable
CompositeMetadata
ConnectionSetupPayload
ErrorFrame
FrameCodec
KeepAliveFrame
LeaseFrame
LoadBalanceRSocket
RSocket load balance [...]
MessageAcceptMimeTypesMetadata
MessageMimeTypeMetadata
MetadataEntry
MetadataPushFrame
Payload
PayloadFrame
RequestChannelFrame
RequestFNFFrame
RequestNFrame
RequestResponseFrame
RequestStreamFrame
RoutingMetadata
RSocket
RSocketConnector
RSocketErrorCode
RSocketFrame
RSocketHeader
RSocketServer
RSocketService
RSocketServiceRouter
RSocketServiceStub
SetupFrame
TaggingMetadata
WellKnownMimeType

Constants

CANCEL → const int
0x09
ERROR → const int
0x0B
EXT → const int
0x3F
KEEPALIVE → const int
0x03
LEASE → const int
0x02
MAJOR_VERSION → const int
1
METADATA_PUSH → const int
0x0C
MINOR_VERSION → const int
0
PAYLOAD → const int
0x0A
REQUEST_CHANNEL → const int
0x07
REQUEST_FNF → const int
0x05
REQUEST_N → const int
0x08
REQUEST_RESPONSE → const int
0x04
REQUEST_STREAM → const int
0x06
RESERVED → const int
0x00
RESUME → const int
0x0D
RESUME_OK → const int
0x0E
SETUP → const int
0x01

Properties

MIME_TYPES Map
final

Functions

decodePayload(RSocketByteBuffer buffer, bool metadataPresent, int frameLength) Payload
fireAndForgetAcceptor(FireAndForget fireAndForget) SocketAcceptor
parseFrame(RSocketByteBuffer byteBuffer) RSocketFrame
parseFrames(List<int> chunk) Iterable<RSocketFrame>
parseWebSocketFrame(List<int> data) RSocketFrame
refillFrameLength(RSocketByteBuffer frameBuffer) → void
requestResponseAcceptor(RequestResponse requestResponse) SocketAcceptor
requestStreamAcceptor(RequestStream requestStream) SocketAcceptor
writePayload(RSocketByteBuffer frameBuffer, Payload payload) → void
writeTFrameTypeAndFlags(RSocketByteBuffer frameBuffer, int frameType, Uint8List metadata, int flags) → void

Typedefs

ErrorConsumer = void Function(RSocketException error)
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)
RSocketCallHandler = dynamic Function(RSocketService rsocketServiceAnnotation, String methodName, List params)
RSocketClose = void Function()
SocketAcceptor = RSocket Function(ConnectionSetupPayload setup, RSocket sendingSocket)

Exceptions / Errors

RSocketException