Struct ClientSession 

pub struct ClientSession { /* private fields */ }

Implementations

impl ClientSession

pub async fn start( &self, target_path: &str, kind: Kind, payload: Bytes, hops: Option<u8>, headers: Map<String, Value>, ) -> Result<ClientStream, ClientError>

pub async fn start_streaming( &self, target_path: &str, kind: Kind, body: Pin<Box<dyn Stream<Item = Result<Bytes, CoreError>> + Send>>, hops: Option<u8>, headers: Map<String, Value>, ) -> Result<ClientStream, ClientError>

pub async fn fetch( &self, request: Request<Bytes>, timeout: Duration, ) -> Result<Response<Bytes>, ClientError>

pub async fn fetch_body( &self, request: Request<WireBody>, timeout: Duration, ) -> Result<Response<WireBody>, ClientError>

pub async fn subscribe( &self, request: Request<Bytes>, timeout: Option<Duration>, ) -> Result<ClientStream, ClientError>

pub async fn discover( &self, target_path: &str, plan: DiscoverPlan, ) -> Result<ClientStream, ClientError>

Trait Implementations

impl Clone for ClientSession

fn clone(&self) -> ClientSession

Returns a duplicate of the value.

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

Performs copy-assignment from source.