Struct StreamBridge 

pub struct StreamBridge<A, B> {
    pub a: A,
    pub b: B,
}

Input to StreamForwardService: the two duplex endpoints to bridge.

Both a and b must be Stream + Sink over the same item type T. To bridge endpoints whose native item types differ, adapt one or both with StreamExt::map / SinkExt::with (or use a duplex wrapper such as rama_udp::ConnectedUdpFramed that exposes the desired type natively) before constructing the bridge.

Fields

a: A

The “left” / a endpoint.

b: B

The “right” / b endpoint.

Implementations

impl<A, B> StreamBridge<A, B>

pub fn new(a: A, b: B) -> StreamBridge<A, B>

Create a new StreamBridge from two duplex endpoints.

Trait Implementations

impl<A, B> Debug for StreamBridge<A, B>

where A: Debug, B: Debug,

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

Formats the value using the given formatter.

impl<A, B, T, EA, EB> Service<StreamBridge<A, B>> for StreamForwardService

where A: Stream<Item = Result<T, EA>> + Sink<T, Error = EA> + Send + Unpin + 'static, B: Stream<Item = Result<T, EB>> + Sink<T, Error = EB> + Send + Unpin + 'static, T: Send + 'static, EA: Into<Box<dyn Error + Send + Sync>> + Send + 'static, EB: Into<Box<dyn Error + Send + Sync>> + Send + 'static,

type Output = BridgeCloseReason

The type of the output returned by the service.

type Error = Box<dyn Error + Send + Sync>

The type of error returned by the service.

async fn serve( &self, bridge: StreamBridge<A, B>, ) -> Result<<StreamForwardService as Service<StreamBridge<A, B>>>::Output, <StreamForwardService as Service<StreamBridge<A, B>>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.