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
- ERROR → const int
- EXT → const int
- KEEPALIVE → const int
- LEASE → const int
- MAJOR_VERSION → const int
- METADATA_PUSH → const int
- MINOR_VERSION → const int
- PAYLOAD → const int
- REQUEST_CHANNEL → const int
- REQUEST_FNF → const int
- REQUEST_N → const int
- REQUEST_RESPONSE → const int
- REQUEST_STREAM → const int
- RESERVED → const int
- RESUME → const int
- RESUME_OK → const int
- SETUP → const int
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)