Struct LargeBlobServiceRegistryClient 

pub struct LargeBlobServiceRegistryClient<T: Transport> {
    pub echo_method_id: u32,
    pub xor_transform_method_id: u32,
    pub checksum_method_id: u32,
    /* private fields */
}

Registry-aware client stub for the #trait_name service.

This client looks up method IDs from a [ServiceRegistry] at construction time, ensuring that method IDs are globally unique across all registered services. It has the same RpcSession requirements as [#client_name].

Fields

echo_method_id: u32

xor_transform_method_id: u32

checksum_method_id: u32

Implementations

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

pub fn new(session: Arc<RpcSession<T>>, registry: &ServiceRegistry) -> Self

Create a new registry-aware client.

Looks up method IDs from the registry. The service must be registered in the registry before calling this constructor.

The session’s demux loop (session.run()) must be running for RPC calls to work.

Panics

Panics if the service or any of its methods are not found in the registry.

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

Get a reference to the underlying session.

pub async fn echo(&self, data: Vec<u8>) -> Result<Vec<u8>, RpcError>

Call the #name method on the remote service.

pub async fn xor_transform( &self, data: Vec<u8>, pattern: u8, ) -> Result<Vec<u8>, RpcError>

Call the #name method on the remote service.

pub async fn checksum(&self, data: Vec<u8>) -> Result<(u32, u32), RpcError>

Call the #name method on the remote service.