okx 0.2.1

OKX交易所API SDK
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use crate::config::Credentials;
use crate::websocket::{Args, ChannelType, OkxWebsocketClient};
use crate::Error;
use tokio::sync::mpsc::Receiver;

pub struct OkxWebsocketApi {
    client: OkxWebsocketClient,
}

impl OkxWebsocketApi {
    pub fn new_public() -> Self {
        let client = OkxWebsocketClient::new_public();
        OkxWebsocketApi { client }
    }

    pub fn new_private(credentials: Credentials) -> Self {
        let client = OkxWebsocketClient::new_private(credentials);
        OkxWebsocketApi { client }
    }

    pub async fn connect(&mut self) -> Result<Receiver<serde_json::Value>, Error> {
        self.client.connect().await
    }

    pub async fn subscribe(&self, channel: ChannelType, args: Args) -> Result<(), Error> {
        self.client.subscribe(channel, args).await
    }

    pub async fn unsubscribe(&self, channel: ChannelType, args: Args) -> Result<(), Error> {
        self.client.unsubscribe(channel, args).await
    }
}