Skip to main content

parse_incoming

Function parse_incoming 

Source
pub fn parse_incoming(text: &str) -> WsIncoming
Expand description

Reads one text frame.

§Examples

use brokapi_bybit_protocol::ws::models::{DataKind, WsIncoming, parse_incoming};

let ok = parse_incoming(r#"{"success":true,"ret_msg":"","conn_id":"x","req_id":"q1","op":"subscribe"}"#);
assert!(matches!(ok, WsIncoming::Ack { success: true, .. }));

let data = parse_incoming(r#"{"topic":"orderbook.1.BTCUSDT","ts":1,"type":"snapshot","data":{"s":"BTCUSDT"},"cts":2}"#);
assert!(matches!(data, WsIncoming::Data { kind: DataKind::Snapshot, cts: 2, .. }));

assert_eq!(parse_incoming(r#"{"op":"pong","args":["1"]}"#), WsIncoming::Pong);