Struct WebSocketBridge 

pub struct WebSocketBridge<Ingress, Egress> {
    pub ingress: Ingress,
    pub egress: Egress,
}

Available on crate features http and std and ws only.

A pair of established WebSocket message transports joined by a relay.

The ingress side faces the downstream client and uses the server protocol role. The egress side faces the upstream server and uses the client role. Keeping this boundary distinct from BridgeIo lets ordinary Rama layers decorate complete WebSocket messages without entering the protocol runtime or decoding raw bytes themselves. The bridge deliberately does not select one side as its extension source; use Self::ingress or Self::egress to access the intended transport explicitly.

Fields

ingress: Ingress

Message transport facing the downstream client.

egress: Egress

Message transport facing the upstream server.

Trait Implementations

impl<Ingress, Egress> Debug for WebSocketBridge<Ingress, Egress>

where Ingress: Debug, Egress: Debug,

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

Formats the value using the given formatter.

impl<S, Ingress, Egress> Service<WebSocketBridge<Ingress, Egress>> for WebSocketRelayService<S>

where S: Service<WebSocketRelayInput>, <S as Service<WebSocketRelayInput>>::Output: Into<WebSocketRelayOutput>, <S as Service<WebSocketRelayInput>>::Error: Into<Box<dyn Error + Sync + Send>>, Ingress: WebSocketIo, Egress: WebSocketIo,

type Output = ()

The type of the output returned by the service.

type Error = Infallible

The type of error returned by the service.

async fn serve( &self, __arg1: WebSocketBridge<Ingress, Egress>, ) -> Result<<WebSocketRelayService<S> as Service<WebSocketBridge<Ingress, Egress>>>::Output, <WebSocketRelayService<S> as Service<WebSocketBridge<Ingress, Egress>>>::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.

impl<S, Ingress, Egress> Service<WebSocketBridge<Ingress, Egress>> for WebSocketRelayEventService<S>

where S: Service<WebSocketRelayEventInput>, <S as Service<WebSocketRelayEventInput>>::Output: Into<WebSocketRelayEventOutput>, <S as Service<WebSocketRelayEventInput>>::Error: Into<Box<dyn Error + Sync + Send>>, Ingress: WebSocketIo, Egress: WebSocketIo,

type Output = ()

The type of the output returned by the service.

type Error = Infallible

The type of error returned by the service.

async fn serve( &self, __arg1: WebSocketBridge<Ingress, Egress>, ) -> Result<<WebSocketRelayEventService<S> as Service<WebSocketBridge<Ingress, Egress>>>::Output, <WebSocketRelayEventService<S> as Service<WebSocketBridge<Ingress, Egress>>>::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.

impl<Inner, Ingress, Egress> Service<WebSocketBridge<Ingress, Egress>> for HARWebSocketService<Inner>

where Inner: Service<WebSocketBridge<HARWebSocket<Ingress>, HARWebSocket<Egress>>>, Ingress: WebSocketIo, Egress: WebSocketIo,

type Output = <Inner as Service<WebSocketBridge<HARWebSocket<Ingress>, HARWebSocket<Egress>>>>::Output

The type of the output returned by the service.

type Error = <Inner as Service<WebSocketBridge<HARWebSocket<Ingress>, HARWebSocket<Egress>>>>::Error

The type of error returned by the service.

async fn serve( &self, __arg1: WebSocketBridge<Ingress, Egress>, ) -> Result<<HARWebSocketService<Inner> as Service<WebSocketBridge<Ingress, Egress>>>::Output, <HARWebSocketService<Inner> as Service<WebSocketBridge<Ingress, Egress>>>::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.