Struct WebsocketStreamsHandle 

pub struct WebsocketStreamsHandle { /* private fields */ }

Implementations

impl WebsocketStreamsHandle

pub fn new(configuration: ConfigurationWebsocketStreams) -> Self

pub async fn connect(&self) -> Result<WebsocketStreams>

Connects to a WebSocket stream using default configuration.

Returns

A Result containing a WebsocketStreams instance if the connection is successful, or an error if the connection fails.

Errors

Returns an anyhow::Error if the connection fails.

Examples

let handle = WebsocketStreamsHandle::new(configuration); let streams = handle.connect().await?;

pub async fn connect_with_config( &self, cfg: WebsocketStreamsConnectConfig, ) -> Result<WebsocketStreams>

Connects to a WebSocket stream with a custom configuration.

Arguments

• cfg - A configuration object specifying connection details for the WebSocket stream.

Returns

A Result containing a WebsocketStreams instance if the connection is successful, or an error if the connection fails.

Errors

Returns an anyhow::Error if the connection fails.

Examples

let handle = WebsocketStreamsHandle::new(configuration); let custom_config = WebsocketStreamsConnectConfig::default(); let streams = handle.connect_with_config(custom_config).await?;

Trait Implementations

impl Clone for WebsocketStreamsHandle

fn clone(&self) -> WebsocketStreamsHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.