hotfix 0.11.1

Buy-side FIX engine written in pure Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use tokio::sync::oneshot;
use tracing::warn;

#[derive(Clone, Debug)]
#[allow(dead_code)]
pub struct ReaderMessage;

pub struct ReaderRef {
    disconnect_signal: oneshot::Receiver<()>,
}

impl ReaderRef {
    pub fn new(disconnect_signal: oneshot::Receiver<()>) -> Self {
        Self { disconnect_signal }
    }

    pub async fn wait_for_disconnect(self) {
        if self.disconnect_signal.await.is_err() {
            warn!("reader dropped without issuing disconnect notification");
        }
    }
}