Struct RocketLeagueStatsClient 

pub struct RocketLeagueStatsClient { /* private fields */ }

Implementations

impl RocketLeagueStatsClient

pub async fn connect(options: ClientOptions) -> Result<Self, RlStatsError>

pub fn connection(&self) -> &ConnectionConfig

pub async fn connect_with_retry( options: ClientOptions, max_attempts: usize, retry_delay: Duration, ) -> Result<Self, RlStatsError>

pub async fn reconnect(&mut self) -> Result<(), RlStatsError>

pub async fn next_event(&mut self) -> Result<Option<StatsEvent>, RlStatsError>

pub async fn next_filtered_event( &mut self, filter: &EventFilter, ) -> Result<Option<StatsEvent>, RlStatsError>

pub fn into_event_stream( self, ) -> impl Stream<Item = Result<StatsEvent, RlStatsError>>

pub fn into_filtered_event_stream( self, filter: EventFilter, ) -> impl Stream<Item = Result<StatsEvent, RlStatsError>>

pub async fn close(self) -> Result<(), RlStatsError>