Struct bybit::ws::Stream

pub struct Stream {
    pub client: Client,
}

Fields

client: Client

Implementations

impl Stream

pub async fn ws_ping(&self, private: bool) -> Result<()>

pub async fn ws_priv_subscribe<'a, F>( &self, req: Subscription<'a>, handler: F ) -> Result<()>

where F: FnMut(WebsocketEvents) -> Result<()> + 'static + Send,

pub async fn ws_subscribe<'a, F>( &self, req: Subscription<'a>, category: Category, handler: F ) -> Result<()>

where F: FnMut(WebsocketEvents) -> Result<()> + 'static + Send,

pub fn build_subscription(action: Subscription<'_>) -> String

pub async fn ws_orderbook( &self, subs: Vec<(i32, &str)>, category: Category, sender: UnboundedSender<OrderBookUpdate> ) -> Result<()>

Subscribes to the specified order book updates and handles the order book events

Arguments

• subs - A vector of tuples containing the order book ID and symbol
• category - The category of the order book

Example

use your_crate_name::Category;
let subs = vec![(1, "BTC"), (2, "ETH")];

pub async fn ws_trades( &self, subs: Vec<&str>, category: Category, sender: UnboundedSender<WsTrade> ) -> Result<()>

This function subscribes to the specified trades and handles the trade events.

Arguments

• subs - A vector of trade subscriptions
• category - The category of the trades

Example

use your_crate_name::Category;
let subs = vec!["BTCUSD", "ETHUSD"];
let category = Category::Linear;
ws_trades(subs, category);

pub async fn ws_tickers( &self, subs: Vec<&str>, category: Category, sender: UnboundedSender<Tickers> ) -> Result<()>

Subscribes to ticker events for the specified symbols and category.

Arguments

• subs - A vector of symbols for which ticker events are subscribed.
• category - The category for which ticker events are subscribed.

Examples

use your_crate_name::Category;
let subs = vec!["BTCUSD", "ETHUSD"];
let category = Category::Linear;
let sender = UnboundedSender<Tickers>;
ws_tickers(subs, category, sender);

pub async fn ws_liquidations( &self, subs: Vec<&str>, category: Category, sender: UnboundedSender<LiquidationData> ) -> Result<()>

pub async fn ws_klines( &self, subs: Vec<(&str, &str)>, category: Category, sender: UnboundedSender<WsKline> ) -> Result<()>

pub async fn ws_position( &self, cat: Option<Category>, sender: UnboundedSender<PositionData> ) -> Result<()>

pub async fn ws_executions( &self, cat: Option<Category>, sender: UnboundedSender<ExecutionData> ) -> Result<()>

pub async fn ws_orders( &self, cat: Option<Category>, sender: UnboundedSender<OrderData> ) -> Result<()>

pub async fn ws_wallet(&self, sender: UnboundedSender<WalletData>) -> Result<()>

pub async fn event_loop<H>( stream: WebSocketStream<MaybeTlsStream<TcpStream>>, handler: H ) -> Result<()>

where H: WebSocketHandler,

Trait Implementations

impl Bybit for Stream

fn new(api_key: Option<String>, secret_key: Option<String>) -> Stream

fn new_with_config( config: &Config, api_key: Option<String>, secret_key: Option<String> ) -> Stream

impl Clone for Stream

fn clone(&self) -> Stream

Returns a copy of the value.

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

Performs copy-assignment from source.