Struct IrohListener

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

A server endpoint using a quinn connection

Implementations

impl<In: RpcMessage, Out: RpcMessage> IrohListener<In, Out>

pub fn new(endpoint: Endpoint) -> Result<Self>

Create a new server channel, given a quinn endpoint, with unrestricted access by node id

The server channel will take care of listening on the endpoint and spawning handlers for new connections.

pub fn new_with_access_control( endpoint: Endpoint, access_control: AccessControl, ) -> Result<Self>

Create a new server endpoint, with specified access control

The server channel will take care of listening on the endpoint and spawning handlers for new connections.

pub fn handle_connections( incoming: Receiver<Connection>, local_addr: SocketAddr, ) -> Self

Create a new server channel, given just a source of incoming connections

This is useful if you want to manage the quinn endpoint yourself, use multiple endpoints, or use an endpoint for multiple protocols.

pub fn handle_substreams( receiver: Receiver<(SendStream, RecvStream)>, local_addr: SocketAddr, ) -> Self

Create a new server channel, given just a source of incoming substreams

This is useful if you want to manage the quinn endpoint yourself, use multiple endpoints, or use an endpoint for multiple protocols.

Trait Implementations

impl<In: RpcMessage, Out: RpcMessage> BoxableListener<In, Out> for IrohListener<In, Out>

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

Clone the listener 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 IrohListener<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> ConnectionErrors for IrohListener<In, Out>

type SendError = Error

Error when sending a message via a channel

type RecvError = Error

Error when receiving a message via a channel

type OpenError = ConnectionError

Error when opening a channel

type AcceptError = ConnectionError

Error when accepting a channel

impl<In: Debug + RpcMessage, Out: Debug + RpcMessage> Debug for IrohListener<In, Out>

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

Formats the value using the given formatter.

impl<In: RpcMessage, Out: RpcMessage> Listener for IrohListener<In, Out>

async fn accept( &self, ) -> Result<(Self::SendSink, Self::RecvStream), AcceptError>

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.

fn boxed(self) -> BoxedListener<Self::In, Self::Out>

where Self: BoxableListener<Self::In, Self::Out> + Sized + 'static,

Box the listener

impl<In: RpcMessage, Out: RpcMessage> StreamTypes for IrohListener<In, Out>

type In = In

The type of messages that can be received on the channel

type Out = Out

The type of messages that can be sent on the channel

type SendSink = SendSink<Out>

Send side of a bidirectional typed channel

type RecvStream = RecvStream<In>

Receive side of a bidirectional typed channel