Struct CrossBridgePeer 

pub struct CrossBridgePeer<U: BridgePeer + ?Sized> { /* private fields */ }

A bridge peer that runs every request and reply through a cross-protocol codec before reaching the inner peer.

Constructed cheaply: the only state is the inner peer’s Arc and the codec. Both are expected to be Send + Sync (the codec is required to be, and the inner peer is a BridgePeer, which already is).

Implementations

impl<U: BridgePeer + ?Sized> CrossBridgePeer<U>

pub fn new( downstream_side: ProtocolSide, codec: Arc<dyn CrossProtocolCodec>, inner: Arc<U>, ) -> Result<Self, BridgeError>

A wrapper around inner that translates through codec.

downstream_side is the protocol the downstream leg speaks; the wrapper passes it to every call so the codec knows which direction to drive. A symmetric codec that handles both directions declares one of them in downstream_protocol and lets the bridge pick the other; the bridge’s downstream_side is the source of truth, not the codec’s declaration.

pub const fn downstream_side(&self) -> ProtocolSide

The protocol this peer reports for the downstream leg.

pub fn codec(&self) -> &Arc<dyn CrossProtocolCodec>

The codec the wrapper runs envelopes through.

pub const fn inner(&self) -> &Arc<U>

The inner upstream peer the codec writes to.

pub fn bridges(&self, ir_method: &str) -> bool

Whether the codec bridges the given IR method.

The bridge loop asks this once at feature-check time, so a method that is not bridged is refused with -32601 before the codec is invoked and the inner peer is contacted. The check is the codec’s wire_method table — the same table the codec uses to translate — so the answer cannot disagree with the codec.

Trait Implementations

impl<U: BridgePeer + ?Sized> BridgePeer for CrossBridgePeer<U>

fn send( &self, envelope: Map<String, Value>, ) -> SendFuture<'_, Result<Map<String, Value>, BridgeError>>

Delivers one envelope and yields the peer’s answer.

fn notify( &self, envelope: Map<String, Value>, ) -> SendFuture<'_, Result<(), BridgeError>>

Delivers one envelope that expects no answer.

fn close(&self) -> SendFuture<'_, Result<(), BridgeError>>

Ends the conversation, flushing anything in flight.

fn listen(&self) -> SendFuture<'_, Result<(), BridgeError>>

Starts delivering frames the peer pushes on its own.

fn take_pending(&self) -> Vec<Map<String, Value>>

Frames the peer received that are the answer to nothing the bridge asked.

fn wait_pending(&self) -> SendFuture<'static, ()>

Resolves once the peer may have something for take_pending.

impl<U: Debug + BridgePeer + ?Sized> Debug for CrossBridgePeer<U>

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

Formats the value using the given formatter.