Crate quic_rpc_utils

Macros

• pin
  Pins a value on the stack.

Structs

• BidiStreaming
  Bidirectional streaming interaction pattern
• ClientStreaming
  Client streaming interaction pattern
• ClientStreamingResponse
• Error
  The Error type, a wrapper around a dynamic error type.
• FlumeConnection
  A flume based connection to a server endpoint.
• FlumeServerEndpoint
  A flume based server endpoint.
• RpcChannel
  A channel for requests and responses for a specific service.
• RpcClient
  A client for a specific service
• RpcServer
  A server channel for a specific service.
• Runtime
  The Tokio runtime.
• ServerStreaming
  Server streaming interaction pattern
• ServerStreamingResponse
• UpdateSink
  Sink that can be used to send updates to the server for the two interaction patterns that support it, crate::message::ClientStreaming and crate::message::BidiStreaming.

Enums

• BidiStreamingError
  Server error when accepting a bidi request
• BidiStreamingItemError
  Server error when receiving an item for a bidi request
• ClientStreamingError
  Server error when accepting a client streaming request
• ClientStreamingItemError
  Server error when receiving an item for a client streaming request
• RpcError
  Client error. All client DSL methods return a Result with this error type.
• ServerStreamingError
  Server error when accepting a server streaming request
• ServerStreamingItemError
  Client error when handling responses from a server streaming request

Traits

• BidiStreamingMsg
  Defines update type and response type for a bidi streaming message.
• ClientStreamingMsg
  Defines update type and response type for a client streaming message.
• ConnectionErrors
  Errors that can happen when creating and using a Connection or ServerEndpoint.
• GetServiceHandler
  获取特定服务的处理程序
• Msg
  Declares the interaction pattern for a message and a service.
• RpcMessage
  Requirements for a RPC message
• RpcMsg
  Defines the response type for a rpc message.
• ServerStreamingMsg
  Defines response type for a server streaming message.
• Service
  A service
• ServiceConnection
  A connection to a specific service on a specific remote machine
• ServiceEndpoint
  A server endpoint for a specific service
• ServiceHandler
  服务的处理程序
• Stream
  A stream of values produced asynchronously.
• StreamExt
  Extension trait for Stream.

Functions

• flume_bounded
  Create a channel with a maximum capacity.
• flume_connection
  Create a flume server endpoint and a connected flume client channel.
• run_server

Type Aliases

• BoxStreamSync
  Sync version of future::stream::BoxStream.
• Result
  Result<T, Error>