acta-maker-sdk 0.3.0

Rust SDK for Acta options market makers — WebSocket client, order signing, message types
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

use tokio::sync::mpsc;

use crate::ws::types::ClientMessage;

use super::ManagedCommand;

/// Opaque peer for acknowledging managed WebSocket commands in downstream tests.
pub struct ManagedWsTestPeer {
    commands: mpsc::Receiver<ManagedCommand>,
}

impl ManagedWsTestPeer {
    #[cfg(not(test))]
    pub(super) const fn new(commands: mpsc::Receiver<ManagedCommand>) -> Self {
        Self { commands }
    }

    /// Receive and acknowledge one ordinary send command.
    pub async fn acknowledge_next_send(&mut self) -> Option<ClientMessage> {
        match self.commands.recv().await? {
            ManagedCommand::Send { message, tx } => {
                let _ = tx.send(Ok(()));
                Some(message)
            }
            _ => None,
        }
    }
}