Struct WebSocketConnector 

pub struct WebSocketConnector { /* private fields */ }

A connector for establishing a WebSocket connection to the Coinbase API.

Implementations

impl WebSocketConnector

This struct is responsible for creating a WebSocket connection to the Coinbase API.

Examples

use bothan_coinbase::api::websocket::WebSocketConnector;

let connector = WebSocketConnector::new("wss://ws-feed.exchange.coinbase.com");
let connection = connector.connect();

pub fn new(url: impl Into<String>) -> Self

Creates a new CoinbaseWebSocketConnector.

pub async fn connect(&self) -> Result<WebSocketConnection, Error>

Connects to the WebSocket and returns a CoinbaseWebSocketConnection.

Trait Implementations

impl AssetInfoProviderConnector for WebSocketConnector

fn connect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<WebSocketConnection, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connects to the WebSocket and returns a WebSocketConnection.

type Provider = WebSocketConnection

The type of provider that this connector creates.

type Error = Error

The type returned in the event of a connection failure.

impl Default for WebSocketConnector

fn default() -> Self

Creates a default CoinbaseWebSocketConnector with the default URL.