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

use crate::ExcService;
use exc_core::types::{SubscribeTrades, TradeStream};
use futures::future::BoxFuture;
use futures::FutureExt;
use tower::ServiceExt;

/// Subscribe trades service.
pub trait SubscribeTradesService {
    /// Subscribe trades.
    fn subscribe_trades(&mut self, inst: &str) -> BoxFuture<'_, crate::Result<TradeStream>>;
}

impl<S> SubscribeTradesService for S
where
    S: ExcService<SubscribeTrades> + Send,
    S::Future: Send,
{
    fn subscribe_trades(&mut self, inst: &str) -> BoxFuture<'_, crate::Result<TradeStream>> {
        ServiceExt::oneshot(self.as_service(), SubscribeTrades::new(inst)).boxed()
    }
}