Skip to main content

binance/futures/
userstream.rs

1use crate::model::{Success, UserDataStream};
2use crate::client::Client;
3use crate::errors::Result;
4use crate::api::API;
5use crate::api::Futures;
6
7#[derive(Clone)]
8pub struct FuturesUserStream {
9    pub client: Client,
10    pub recv_window: u64,
11}
12
13impl FuturesUserStream {
14    // User Stream
15    pub fn start(&self) -> Result<UserDataStream> {
16        self.client.post(API::Futures(Futures::UserDataStream))
17    }
18
19    pub fn keep_alive(&self, listen_key: &str) -> Result<Success> {
20        self.client
21            .put(API::Futures(Futures::UserDataStream), listen_key)
22    }
23
24    pub fn close(&self, listen_key: &str) -> Result<Success> {
25        self.client
26            .delete(API::Futures(Futures::UserDataStream), listen_key)
27    }
28}