Struct BetfairStreamClient 

pub struct BetfairStreamClient { /* private fields */ }

Betfair Exchange Stream API client using raw TLS (CRLF-delimited JSON).

On connect, authenticates immediately. On reconnection, replays authentication and any active subscriptions with the latest clk token for delta resumption.

The auth bytes are stored in a watch channel so the caller can push refreshed session tokens via update_auth after keep-alive or HTTP reconnect. The closed flag distinguishes permanent shutdown from transient reconnect.

Implementations

impl BetfairStreamClient

pub async fn connect( credential: &BetfairCredential, session_token: String, handler: TcpMessageHandler, config: BetfairStreamConfig, ) -> Result<Self, BetfairStreamError>

Connects to the Betfair stream API and authenticates.

Errors

Returns an error if the connection fails or authentication cannot be sent.

pub async fn subscribe_markets( &self, market_filter: StreamMarketFilter, data_filter: MarketDataFilter, heartbeat_ms: Option<u64>, conflate_ms: Option<u64>, ) -> Result<(), BetfairStreamError>

Subscribes to market data for the given filter and data fields.

Stores the subscription for automatic replay on reconnection.

Errors

Returns an error if serialization or sending fails.

pub async fn subscribe_orders( &self, order_filter: Option<OrderFilter>, heartbeat_ms: Option<u64>, ) -> Result<(), BetfairStreamError>

Subscribes to order updates.

Stores the subscription for automatic replay on reconnection.

Errors

Returns an error if serialization or sending fails.

pub fn is_active(&self) -> bool

Returns true if the connection is active.

pub fn update_auth(&self, app_key: &str, session_token: String)

Pushes refreshed auth bytes so the next reconnection or subscription uses the current session token instead of the one from initial connect.

pub async fn close(&self)

Closes the stream connection.

Trait Implementations

impl Debug for BetfairStreamClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.