shelf library Null safety

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