Struct OperatorStatePoller 

pub struct OperatorStatePoller { /* private fields */ }

Handle to a running operator-state poller.

Dropping the handle does not stop the task; callers must explicitly .shutdown().await for a clean exit. Matches the WsSubscriber handle’s semantics.

Implementations

impl OperatorStatePoller

pub fn spawn(http: HttpClient, state: Arc<RwLock<EngineState>>) -> Self

Spawn a poller that writes into state every POLL_INTERVAL. Returns immediately — the first fetch happens in the background task on the first tick.

pub fn spawn_with_interval( http: HttpClient, state: Arc<RwLock<EngineState>>, interval: Duration, ) -> Self

Like Self::spawn with a custom interval — used by tests that want to exercise multiple polls in a short wall-clock window.

pub async fn shutdown(self) -> Result<(), JoinError>

Signal the task to exit and wait for it.

Errors

Returns the tokio join error verbatim on panic or cancel; clean shutdown always returns Ok.

Trait Implementations

impl Debug for OperatorStatePoller

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

Formats the value using the given formatter.