Struct ObserverChannel 

pub struct ObserverChannel { /* private fields */ }

Bounded-mpsc observer trampoline. Constructed by each language binding’s set_observer implementation; installed on the mesh via super::super::MeshNode::set_rpc_observer.

The substrate dispatch path’s RpcObserver::on_call pays only Arc::clone + try_send + atomic counter on overflow — every allocation / GIL-acquisition / TSFN call defers to the worker drained off the dispatch thread.

Implementations

impl ObserverChannel

pub fn install<F>(runtime: &Handle, dispatch: F) -> Self

where F: Fn(Arc<RpcCallEvent>) + Send + 'static,

Build a bounded channel + spawn a drain worker on the given runtime handle. dispatch runs once per drained event on the worker task — bindings put their language-specific invocation here (TSFN, GIL acquisition + Python call, C function-pointer call).

The worker exits cleanly when the channel closes (every ObserverChannel is dropped + no more senders exist).

Trait Implementations

impl RpcObserver for ObserverChannel

fn on_call(&self, evt: RpcCallEvent)

Fired once per observed RPC boundary. Must be cheap — the dispatch thread blocks until the call returns.