Struct fire_stream_api::client::Client

pub struct Client<A, B> { /* private fields */ }

Implementations

impl<A> Client<A, PlainBytes>where A: Action + Send + 'static,

pub fn new<S>( stream: S, cfg: Config, recon_strat: Option<ReconStrat<S>> ) -> Selfwhere S: ByteStream,

impl<A> Client<A, EncryptedBytes>where A: Action + Send + 'static,

pub fn new_encrypted<S>( stream: S, cfg: Config, recon_strat: Option<ReconStrat<S>>, pub_key: PublicKey ) -> Selfwhere S: ByteStream,

Available on crate feature encrypted only.

impl<A, B> Client<A, B>where A: Action, B: PacketBytes,

pub async fn request<R>(&self, req: R) -> Result<R::Response, R::Error>where R: Request<Action = A> + IntoMessage<A, B>, R::Response: FromMessage<A, B>, R::Error: FromMessage<A, B>,

impl<A, B> Client<A, B>

pub async fn close(self) -> Result<(), TaskError>