Struct TranscoderEndpoint 

pub struct TranscoderEndpoint<R, SendMsg>
where
    R: Transcoder,
    SendMsg: Send + 'static,
{ /* private fields */ }

Recv-only protocol transcoder endpoint.

Wraps an inner Endpoint<R::Input, SendMsg> and presents Endpoint<R::Output, SendMsg>:

• recv (output direction): stateful stream transformation via R: Transcoder — emits prologue, transcodes each item, then emits epilogue.
• send (input direction): passes through to the inner endpoint unchanged.

Implementations

impl<R, SendMsg> TranscoderEndpoint<R, SendMsg>

where R: Transcoder + 'static, SendMsg: Send + 'static,

pub fn new( inner: Arc<dyn Endpoint<R::Input, SendMsg>>, recv_transcoder: R, ) -> Self

Trait Implementations

impl<R, SendMsg> Endpoint<<R as Transcoder>::Output, SendMsg> for TranscoderEndpoint<R, SendMsg>

where R: Transcoder + 'static, SendMsg: Send + 'static,

fn recv<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<R::Output>, TransportError>> + Send + 'async_trait>>

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

fn send<'life0, 'async_trait>( &'life0 self, item: SendMsg, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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