Struct BetfairRaceStreamClient 

pub struct BetfairRaceStreamClient { /* private fields */ }

Betfair race stream client for Total Performance Data (TPD).

Connects to sports-data-stream-api.betfair.com and subscribes to Race Change Messages (RCM) with live GPS tracking data. Simpler than BetfairStreamClient: no clk-based delta resumption, just auth + raceSubscription on (re)connect.

Implementations

impl BetfairRaceStreamClient

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

Connects to the Betfair race stream and subscribes.

The race_fatal_tx channel receives a signal when the server returns a fatal status error (e.g. NOT_AUTHORIZED, no TPD entitlement). The caller should monitor this channel and close the client when it fires.

Errors

Returns an error if the connection fails or the initial send 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 uses the current session token instead of the one from initial connect.

pub async fn close(&self)

Closes the race stream connection.

Trait Implementations

impl Debug for BetfairRaceStreamClient

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

Formats the value using the given formatter.