rs_limitless 0.1.1

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

pub mod channel;
pub mod client;
pub mod stream;
pub use channel::*;
pub use stream::*;

use tokio::time::Duration;

use crate::prelude::*;
use tokio::sync::mpsc;

/// Interval at which the WebSocket event loop sends a ping to keep the
/// connection alive (the Limitless WS uses Socket.IO-level pings internally,
/// but we maintain our own keep-alive on the raw WebSocket).
pub(crate) const PING_INTERVAL: Duration = Duration::from_secs(25);

/// Helper: send an item through an unbounded channel, mapping the error
/// to `LimitlessError`.
#[allow(dead_code)]
pub(crate) fn send_or_err<T>(
    sender: &mpsc::UnboundedSender<T>,
    item: T,
) -> Result<(), LimitlessError> {
    sender
        .send(item)
        .map_err(|e| LimitlessError::ChannelSendError {
            underlying: e.to_string(),
        })
}