exc 0.7.3

The abstraction layer of exchanges.
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
33
34
35
36
37
38
39
40
41
42
43
44
45

use exc_core::types::BidAskStream;
use futures::future::BoxFuture;
use futures::FutureExt;
use tower::ServiceExt;

use crate::core::types::SubscribeBidAsk;

use crate::ExcService;

/// Subscribe current best bid and ask service.
pub trait SubscribeBidAskService {
    /// Subscribe current best bid and ask.
    fn subscribe_bid_ask(&mut self, inst: &str) -> BoxFuture<'_, crate::Result<BidAskStream>>;
}

impl<S> SubscribeBidAskService for S
where
    S: ExcService<SubscribeBidAsk> + Send,
    S::Future: Send,
{
    /// Subscribe current best bid and ask.
    fn subscribe_bid_ask(&mut self, inst: &str) -> BoxFuture<'_, crate::Result<BidAskStream>> {
        ServiceExt::oneshot(self.as_service(), SubscribeBidAsk::new(inst)).boxed()
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[allow(dead_code)]
    fn boxed_bid_ask<'a, S>(svc: S) -> Box<dyn SubscribeBidAskService + 'a>
    where
        S: SubscribeBidAskService + 'a,
    {
        Box::new(svc)
    }

    #[cfg(feature = "binance")]
    #[tokio::test]
    async fn test_box_bid_ask() {
        let binance = crate::Binance::usd_margin_futures().connect_exc();
        std::hint::black_box(boxed_bid_ask(binance));
    }
}