Struct RangeServiceClient 

pub struct RangeServiceClient<T: Transport> { /* private fields */ }

Client stub for the #trait_name service.

This client uses hardcoded method IDs (1, 2, …) and expects an Arc<RpcSession<T>> whose run task is already running. Construct sessions with RpcSession::with_channel_start to coordinate odd/even channel IDs when both peers initiate RPCs. For multi-service scenarios where method IDs must be globally unique, use [#registry_client_name] instead.

Usage

let session = Arc::new(RpcSession::new(transport));
tokio::spawn(session.clone().run()); // Start the demux loop
let client = FooClient::new(session);
let result = client.some_method(args).await?;

Implementations

impl<T: Transport + Send + Sync + 'static> RangeServiceClient<T>

pub fn new(session: Arc<RpcSession<T>>) -> Self

Create a new client with the given RPC session.

Uses hardcoded method IDs (1, 2, …). For registry-based method IDs, use [#registry_client_name::new] instead.

The provided session must be shared (Arc::clone) with the call site and have its demux loop (tokio::spawn(session.clone().run())) running.

pub fn session(&self) -> &Arc<RpcSession<T>>

Get a reference to the underlying session.

pub async fn range(&self, n: u32) -> Result<Streaming<u32>, RpcError>

Call the #name server-streaming method on the remote service.

Returns a stream that yields items as they arrive from the server. The stream ends when the server sends EOS, or yields an error if the server sends an ERROR frame.