radion-sdk 0.2.1

//! Realtime (WebSocket) product surface.
//!
//! Connect a [`RealtimeClient`], [`subscribe`](RealtimeClient::subscribe) to
//! channels, and consume the returned [`Stream`](futures_util::Stream) of typed
//! [`ChannelEvent`]s. The client transparently reconnects, restores
//! subscriptions, and heartbeats the connection.

mod channels;
mod client;
mod payloads;
mod protocol;
mod reconnect;
mod subscription;

pub use channels::{CHANNELS, Channel, FilterKey, SubscribableChannel};
pub use client::{
    ChannelEventStream, HeartbeatOptions, LifecycleEvent, LifecycleStream, RealtimeClient,
    RealtimeOptions,
};
pub use payloads::{
    ActivityEventType, ActivityPayload, CollateralEventType, CollateralPayload, CombosEventType,
    CombosPayload, Hex, LifecycleEventType, LifecyclePayload, OracleEventType, OraclePayload,
    Payload, PricesPayload, TradeEventType, TradesPayload,
};
pub use protocol::{ChannelEvent, ChannelFilters, Subscription};
pub use reconnect::ReconnectOptions;