openlimits-exchange 0.3.0

The exchange traits of OpenLimits.
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

use std::sync::Arc;
use std::sync::RwLock;
use crate::errors::OpenLimitsError;
use super::shared::Result;
use super::MarketPairInfo;


#[derive(Debug)]
pub struct MarketPairHandle {
    pub inner: Arc<RwLock<MarketPairInfo>>,
}

impl<'a> MarketPairHandle {
    pub fn new(inner: Arc<RwLock<MarketPairInfo>>) -> Self {
        Self { inner }
    }

    pub fn read(&'a self) -> Result<MarketPairInfo> {
        self.inner
            .read()
            .map(|guard| guard.clone())
            .map_err(|_| OpenLimitsError::PoisonError())
    }
}

impl<'a> serde::Serialize for MarketPairHandle {
    fn serialize<S>(&self, serializer: S) -> std::result::Result<S::Ok, S::Error>
    where
        S: serde::Serializer,
    {
        serializer.collect_str(&self.inner.read().expect("Couldn't read pairs.").symbol)
    }
}