Struct WebSocketRelayInjector 

pub struct WebSocketRelayInjector { /* private fields */ }

Available on crate features http and std and ws only.

A handle for injecting application data into a live WebSocket MITM relay.

Relay middleware can retrieve this handle from its extensions after message injection is enabled on the relay service.

The supplied WebSocketRelayDirection describes the direction the message travels: ingress messages are sent to the upstream peer, while egress messages are sent to the downstream peer. Injected messages bypass relay middleware because they did not originate from either peer.

Implementations

impl WebSocketRelayInjector

pub fn is_open(&self) -> bool

Returns whether both sides of the relay can still accept injected data.

pub async fn closed(&self)

Wait until the relay has stopped accepting injected messages.

pub async fn send( &self, direction: WebSocketRelayDirection, message: WebSocketRelayMessage, ) -> Result<(), ProtocolError>

Send an application data message through the live relay.

This resolves only after the destination WebSocket sink accepted and flushed the message. A full injection queue returns ProtocolError::WriteBufferFull with the original message, an oversized payload returns ProtocolError::MessageTooLong, and a closed relay is reported as an I/O-flavoured ProtocolError.

Trait Implementations

impl Clone for WebSocketRelayInjector

fn clone(&self) -> WebSocketRelayInjector

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WebSocketRelayInjector

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

Formats the value using the given formatter.

impl Extension for WebSocketRelayInjector