Extensions

Transports

TCP

class rsocket.transports.tcp.TransportTCP(reader, writer, read_buffer_size=1024)[source]

RSocket transport over asyncio TCP connection.

Parameters:

reader (StreamReader) – asyncio connection reader stream
writer (StreamWriter) – asyncio connection writer stream

Websocket

aiohttp

quart

quic

http3

Routing

RequestRouter

class rsocket.routing.request_router.RequestRouter(payload_deserializer=<function RequestRouter.<lambda>>, payload_serializer=<function RequestRouter.<lambda>>)[source]

Used to define routes for RSocket endpoints.

Pass this to RoutingRequestHandler to instantiate a handler using these routes.

RoutingRequestHandler

class rsocket.routing.routing_request_handler.RoutingRequestHandler(router, authentication_verifier=None)[source]

Handler implementation which uses a RequestRouter to handle requests based on route information provided in the payload metadata.