Struct FlumeServerEndpoint

pub struct FlumeServerEndpoint<In: RpcMessage, Out: RpcMessage> { /* private fields */ }

A flume based server endpoint.

Created using connection.

Trait Implementations

impl<In: RpcMessage, Out: RpcMessage> BoxableServerEndpoint<In, Out> for FlumeServerEndpoint<In, Out>

fn clone_box(&self) -> Box<dyn BoxableServerEndpoint<In, Out>>

Clone the server endpoint and box it

fn accept_bi_boxed(&self) -> AcceptFuture<'_, In, Out>

Accept a channel from a remote client

fn local_addr(&self) -> &[LocalAddr]

Get the local address

impl<In: RpcMessage, Out: RpcMessage> Clone for FlumeServerEndpoint<In, Out>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<In: RpcMessage, Out: RpcMessage> ConnectionCommon<In, Out> for FlumeServerEndpoint<In, Out>

type SendSink = SendSink<Out>

Send side of a bidirectional typed channel

type RecvStream = RecvStream<In>

Receive side of a bidirectional typed channel

impl<In: RpcMessage, Out: RpcMessage> ConnectionErrors for FlumeServerEndpoint<In, Out>

type SendError = SendError

Error when sending a message via a channel

type RecvError = RecvError

Error when receiving a message via a channel

type OpenError = AcceptBiError

Error when opening or accepting a channel

impl<In: RpcMessage, Out: RpcMessage> Debug for FlumeServerEndpoint<In, Out>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<In: RpcMessage, Out: RpcMessage> ServerEndpoint<In, Out> for FlumeServerEndpoint<In, Out>

fn accept(&self) -> AcceptBiFuture<In, Out>

Accept a new typed bidirectional channel on any of the connections we have currently opened.

fn local_addr(&self) -> &[LocalAddr]

The local addresses this endpoint is bound to.