Trait quic_rpc::transport::ServerEndpoint

pub trait ServerEndpoint<In, Out>: ConnectionCommon<In, Out> {
    // Required methods
    fn accept_bi(
        &self
    ) -> impl Future<Output = Result<(Self::SendSink, Self::RecvStream), Self::OpenError>> + Send;
    fn local_addr(&self) -> &[LocalAddr];
}

A server endpoint that listens for connections

A server endpoint can be used to accept bidirectional typed channels from any of the currently opened connections to clients, using ServerEndpoint::accept_bi.

Required Methods

fn accept_bi( &self ) -> impl Future<Output = Result<(Self::SendSink, Self::RecvStream), Self::OpenError>> + Send

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.

Object Safety

This trait is not object safe.

Implementors

impl<A: ServerEndpoint<S::Req, S::Res>, B: ServerEndpoint<S::Req, S::Res>, S: Service> ServerEndpoint<<S as Service>::Req, <S as Service>::Res> for CombinedServerEndpoint<A, B, S>

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

impl<S: Service> ServerEndpoint<<S as Service>::Req, <S as Service>::Res> for FlumeServerEndpoint<S>

impl<S: Service> ServerEndpoint<<S as Service>::Req, <S as Service>::Res> for HyperServerEndpoint<S>

impl<S: Service> ServerEndpoint<<S as Service>::Req, <S as Service>::Res> for QuinnServerEndpoint<S>