Struct diem_client::stream::StreamingClient

pub struct StreamingClient { /* private fields */ }

This API is experimental and subject to change Documentation is in /json-rpc/src/stream_rpc/README.md

Implementations

impl StreamingClient

pub async fn new<T: Into<String>>( url: T, config: StreamingClientConfig, websocket_config: Option<WebSocketConfig> ) -> StreamResult<Self>

pub async fn subscribe_transactions( &mut self, starting_version: u64, include_events: Option<bool> ) -> StreamResult<SubscriptionStream>

pub async fn subscribe_events( &mut self, event_key: EventKey, event_seq_num: u64 ) -> StreamResult<SubscriptionStream>

pub async fn send_subscription( &mut self, request: StreamMethodRequest ) -> StreamResult<SubscriptionStream>

pub async fn subscription_count(&self) -> usize

Trait Implementations

impl Clone for StreamingClient

fn clone(&self) -> StreamingClient

Returns a copy of the value.

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

Performs copy-assignment from source.