Trait IncomingChannelFactory 

pub trait IncomingChannelFactory: Send + Sync {
    type Stream: Send + Sync + 'static;

    // Required method
    fn accept_from_transport<'life0, 'async_trait>(
        &'life0 self,
        peer: Sensitive<SocketAddr>,
        stream: Self::Stream,
        memquota: ChannelAccount,
    ) -> Pin<Box<dyn Future<Output = Result<Arc<Channel>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Similar to ChannelFactory, but for building channels from incoming streams.

Required Associated Types

type Stream: Send + Sync + 'static

The type of byte stream that’s required to build channels for incoming connections.

Required Methods

fn accept_from_transport<'life0, 'async_trait>( &'life0 self, peer: Sensitive<SocketAddr>, stream: Self::Stream, memquota: ChannelAccount, ) -> Pin<Box<dyn Future<Output = Result<Arc<Channel>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Open a channel from peer with the given stream. The channel may or may not be authenticated.

Implementors

impl<CF: IncomingChannelFactory> IncomingChannelFactory for CompoundFactory<CF>

type Stream = <CF as IncomingChannelFactory>::Stream

impl<R, H> IncomingChannelFactory for ChanBuilder<R, H>

where R: TlsProvider<H::Stream> + Send + Sync + Runtime, H: Send + Sync + TransportImplHelper,

type Stream = <H as TransportImplHelper>::Stream