hotfix 0.12.0

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
23
24
25
26

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

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

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

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

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