Struct GameStateListener 

pub struct GameStateListener { /* private fields */ }

HTTP listener for CS2 GSI payloads.

Cheap to clone — every clone shares the same dispatcher and last-state cache. Handlers registered through any clone fire on every payload.

Implementations

impl GameStateListener

pub fn new(port: u16) -> Self

Create a listener that will bind to 127.0.0.1:<port> when started.

pub fn with_addr(addr: SocketAddr) -> Self

Create a listener with a fully specified bind address.

pub fn addr(&self) -> SocketAddr

The configured bind address. After start succeeds, this is also returned by actual_addr.

pub fn actual_addr(&self) -> Option<SocketAddr>

The actual bound socket address — useful when you bind to port 0 and want to discover the OS-assigned port.

pub fn on<E, F>(&self, handler: F) -> &Self

where E: Any + Send + Sync + 'static, F: Fn(&E) + Send + Sync + 'static,

Subscribe to a strongly typed event.

let gsl = GameStateListener::new(4000);
gsl.on(|e: &PlayerGotKill| {
    println!("{} now has {} round kills", e.player.name, e.new_round_kills);
});

pub fn on_any<F>(&self, handler: F) -> &Self

where F: Fn(&GameEvent) + Send + Sync + 'static,

Subscribe to every event as a GameEvent.

pub fn current_state(&self) -> Option<GameState>

The most recently received game state, if any.

pub fn is_running(&self) -> bool

true once start has succeeded and before stop is called.

pub async fn start(&self) -> Result<()>

Bind the listener and start accepting GSI payloads. Returns once the socket is bound — the actual serve loop runs as a background tokio task. Call stop to shut it down.

pub async fn start_with_fallbacks<I>(&self, fallbacks: I) -> Result<()>

where I: IntoIterator<Item = SocketAddr>,

Bind, falling back to alternative addresses if the primary is busy.

Tries self.addr first. If that address is reported as in use (after the per-address retry budget is exhausted), each fallback is tried in turn. The first address that binds wins; the actual chosen address is then available via actual_addr.

Pass port = 0 as a final fallback to ask the OS to pick any free ephemeral port — that bind effectively cannot fail.

All non-AddrInUse errors short-circuit immediately (no point trying fallbacks if e.g. the loopback interface is gone).

pub async fn stop(&self) -> Result<()>

Signal the serve loop to exit and wait for it to finish.

Trait Implementations

impl Clone for GameStateListener

fn clone(&self) -> GameStateListener

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.