Module rpc_it::rpc

RPC connection implementation

Cautions

• All write operation are not cancellation-safe in async context. Once you abort the async write task such as request, notify, response* series, the write stream may remain in corrupted state, which may invalidate any subsequent write operation.

Modules

• msg

Structs

• Builder
• EmptyEventListener
  Placeholder implementation of event listener.
• Feature
• OwnedResponseFuture
• OwnedUserData
• RequestContext
  RPC request context. Stores request ID and response receiver context.
• ResponseFuture
  When dropped, the response handler will be unregistered from the queue.
• Sender
  Send-only handle. This holds strong reference to the connection.
• Transceiver
  Bidirectional RPC handle. It can serve as both client and server.
• WriteBuffer
  Reused buffer over multiple RPC request/responses

Enums

• CallError
• InboundError
• RecvError
• SendError
• TryRecvError
• TypedCallError

Traits

• ExtractUserData
• GetRequestContext
  Trick to get the request context from the generic type, and to cast [ConnectionBody] to dyn [Connection] trait object.
• InboundEventSubscriber
  This trait is to notify the event from the connection.
• Message
• MessageMethodName
• MessageReqId
• UserData