Struct ClientListener 

pub struct ClientListener { /* private fields */ }

The client’s sockets, bound and waiting for the engines.

Binding first lets a launcher bind tcp://<host>:0, read the port the OS chose from ClientListener::handshake_address, and start the engines with it.

Implementations

impl ClientListener

pub async fn bind(config: ClientConfig) -> Result<Self>

Bind the handshake, input and output sockets.

pub fn handshake_address(&self) -> &str

The handshake address the engines must dial, as bound.

pub async fn accept(self) -> Result<EngineClient>

Wait until every engine has registered, within the configured handshake timeout.

Must be called within a Tokio runtime; the client’s background tasks run on it.