Struct LateBoundForwarder 

pub struct LateBoundForwarder { /* private fields */ }

A dispatcher that forwards all requests to a late-bound upstream connection.

Like ForwardingDispatcher, but the upstream handle is provided after creation via LateBoundHandle::set. This enables bidirectional proxying scenarios.

If a request arrives before the handle is bound, it returns Cancelled.

Example

// Create late-bound handle and forwarder
let late_bound = LateBoundHandle::new();
let forwarder = LateBoundForwarder::new(late_bound.clone());

// Use forwarder with connect() for reverse-direction calls
let virtual_conn = handle.connect(metadata, Some(Box::new(forwarder))).await?;

// Later, bind the actual handle
let (browser_handle, driver) = accept_framed(...).await?;
late_bound.set(browser_handle);

Implementations

impl LateBoundForwarder

pub fn new(upstream: LateBoundHandle) -> Self

Create a new late-bound forwarding dispatcher.

Trait Implementations

impl Clone for LateBoundForwarder

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServiceDispatcher for LateBoundForwarder

fn method_ids(&self) -> Vec<u64>

Returns the method IDs this dispatcher handles.

fn dispatch( &self, cx: &Context, payload: Vec<u8>, registry: &mut ChannelRegistry, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'static>>

Dispatch a request and send the response via the task channel.