rs_limitless 0.1.2

Limitless Exchange API bindings in Rust — prediction market trading, HMAC authentication, EIP-712 signing, and WebSocket streams.
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

use crate::prelude::*;

/// Manages a WebSocket connection lifecycle.
///
/// Wraps a `WebSocketStream` and provides connect/disconnect with
/// proper WebSocket Close frame semantics.
pub struct WsClient {
    stream: WebSocketStream<MaybeTlsStream<TcpStream>>,
}

impl WsClient {
    /// Create a new `WsClient` from an already-established `WebSocketStream`.
    pub fn new(stream: WebSocketStream<MaybeTlsStream<TcpStream>>) -> Self {
        Self { stream }
    }

    /// Get a mutable reference to the underlying stream.
    pub fn stream(&mut self) -> &mut WebSocketStream<MaybeTlsStream<TcpStream>> {
        &mut self.stream
    }

    /// Send a WebSocket Close frame and consume the connection.
    pub async fn disconnect(&mut self) -> Result<(), LimitlessError> {
        self.stream
            .close(None)
            .await
            .map_err(|e| LimitlessError::Base(format!("Error closing WebSocket: {}", e)))?;
        Ok(())
    }
}