Struct diem_sdk::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>( url: T, config: StreamingClientConfig, websocket_config: Option<WebSocketConfig> ) -> impl Future<Output = Result<StreamingClient, StreamError>>where T: Into<String>,

pub async fn subscribe_transactions( &mut self, starting_version: u64, include_events: Option<bool> ) -> impl Future<Output = Result<SubscriptionStream, StreamError>>

pub async fn subscribe_events( &mut self, event_key: EventKey, event_seq_num: u64 ) -> impl Future<Output = Result<SubscriptionStream, StreamError>>

pub async fn send_subscription( &mut self, request: StreamMethodRequest ) -> impl Future<Output = Result<SubscriptionStream, StreamError>>

pub async fn subscription_count(&self) -> impl Future<Output = 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.