Struct Hub 

pub struct Hub { /* private fields */ }

Implementations

impl Hub

pub fn new() -> Self

pub fn next_conn_id(&self) -> u64

pub fn register(&self, identity: &str, handle: ConnHandle) -> Option<ConnHandle>

Registers a connection, returning the handle it replaced (if any).

pub fn unregister(&self, identity: &str, conn_id: u64)

Removes the entry only if it still belongs to conn_id.

pub fn get(&self, identity: &str) -> Option<ConnHandle>

pub fn is_empty(&self) -> bool

pub fn len(&self) -> usize

pub fn list(&self) -> Vec<ConnInfo>

pub async fn call( &self, identity: &str, action: &str, payload: Value, wait: Duration, ) -> Result<CallOutcome, SendError>

Queues a CALL on the station’s connection and waits for its outcome. The session sends CALLs one at a time (OCPP-J §4.1.1), so wait covers queueing plus the call timeout.

Trait Implementations

impl Default for Hub

fn default() -> Self

Returns the “default value” for a type.