Struct copra::channel::Channel

pub struct Channel { /* fields omitted */ }

Communication channel between servers

The Channel implements Clone, Send, and Sync. Once a channel is create from a ChannelBuilder, it can be cloned and used in multiple threads.

Methods

impl Channel

fn new(
    sender: UnboundedSender<(Sender<Result<((RpcResponseMeta, Bytes), FeedbackHandle)>>, (RpcRequestMeta, Bytes))>,
    max_concurrency: u32
) -> Self

Create a new channel.

This method is used by ChannelBuilder.

fn call(&self, req: (RpcRequestMeta, Bytes)) -> ChannelFuture

Issue a request.

This method deals with serialized, untyped message. It is meaned to be used internally by the framework. More ergonomic interfaces are provided by the auto-generated stubs.

fn congested(&self) -> bool

Check if the channel is currently congested (i.e. concurrency limit is reached).

Trait Implementations

impl Clone for Channel

fn clone(&self) -> Channel

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Channel

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.