Crate muxio_rpc_service_endpoint 

Modules

error

Structs

RpcServiceEndpoint

A concrete RPC service endpoint, generic over a context type C.

StreamResponder

Handle for sending properly framed response chunks back to the caller from within a streaming handler. Writes go directly to the transport via a pre-created RpcStreamEncoder (set after read_bytes returns), so the responder can be stored and used from background tasks.

Traits

RpcServiceEndpointInterface

WithHandlers

A trait that provides a generic, asynchronous interface for accessing a shared HashMap of RPC handlers protected by a mutex.

WithStreamHandlers

A trait that provides a generic, asynchronous interface for accessing a shared HashMap of streaming RPC handlers protected by a mutex.

Functions

process_single_prebuffered_request

Processes a single finalized RPC request, executes its handler, and returns the response.

Type Aliases

RpcPrebufferedHandler

RpcStreamHandler

A streaming RPC handler receives individual RpcStreamEvents as they arrive from the transport, along with a StreamResponder for sending properly framed response chunks back to the caller.