Struct Provider 

pub struct Provider { /* private fields */ }

General Provider, which holding reference of Processor Provider should be obey memory layout of CLang Provider should be export for wasm-bindgen

Implementations

impl Provider

pub fn from_processor(processor: Arc<Processor>) -> Self

Create provider from processor directly

pub fn extensions(&self) -> Extensions

The shared protocol registry. The inbound callback clones this so registration (via the provider) and dispatch see the same table.

pub fn register_protocol<P, I>(&self, protocol: P, interpret: I) -> Result<()>

where P: Protocol + MaybeSend + 'static, P::State: MaybeSend + 'static, P::Effect: MaybeSend, I: Interpret<Effect = P::Effect> + MaybeSend + 'static,

Register a pure Protocol together with its Interpret shell under the protocol’s namespace. Errors if the namespace is already taken.

pub async fn send(&self, to: Did, namespace: &str, payload: Bytes) -> Result<()>

Send a namespaced payload to a peer. This is the uniform upper-layer send — a core capability, identical on native and browser.

pub async fn peer_measurement(&self, did: Did) -> Option<PeerMeasurement>

Return local measurement counters for a peer, if observed.

pub async fn peer_measurements(&self) -> Vec<PeerMeasurement>

Return every retained local peer measurement.

pub fn set_backend(&self) -> Result<()>

Install the extension Backend as the swarm’s inbound callback, so inbound custom messages are decoded as Envelopes and routed to their namespace’s protocol. Call once after registering protocols.

pub fn set_swarm_callback(&self, callback: SharedSwarmCallback) -> Result<()>

👎Deprecated:

set_swarm_callback will be removed in next version, plz use set_backend instead

Set callback for swarm.

pub async fn request_internal( &self, method: String, params: Value, ) -> Result<Value>

Request local rpc interface the internal rpc interface is provide by rings_rpc

impl Provider

pub async fn request<T>(&self, method: Method, params: T) -> Result<Value>

where T: Serialize,

A request function implementation for native provider

pub async fn listen(&self)

Listen for messages until this future is dropped or aborted.

This is a long-running task; do not await completion as a readiness signal.

pub async fn listen_with(&self, stop: StopToken)

Listen for messages until stop requests cooperative shutdown.

This is a long-running task; do not await completion as a readiness signal.

Trait Implementations

impl Clone for Provider

fn clone(&self) -> Provider

Returns a duplicate of the value.

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

Performs copy-assignment from source.