Struct Reactor

pub struct Reactor { /* private fields */ }

Implementations

impl Reactor

pub fn spawn( capacity: usize, requests: Sender<Request>, notifications: Sender<Notification>, ) -> (Self, Sender<Response>)

pub async fn notify<M, P>( &mut self, method: M, params: P, timeout: Option<Duration>, ) -> bool

where M: AsRef<str>, P: Into<Params>,

pub async fn request<M, P>( &mut self, method: M, params: P, timeout: Option<Duration>, ) -> Option<Receiver<Result<Value, RpcError>>>

where M: AsRef<str>, P: Into<Params>,

pub async fn request_with_id<M, P>( &mut self, id: Id, method: M, params: P, timeout: Option<Duration>, ) -> Option<Receiver<Result<Value, RpcError>>>

where M: AsRef<str>, P: Into<Params>,

Trait Implementations

impl Debug for Reactor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.