Struct Handle 

pub struct Handle { /* private fields */ }

A worker’s cloneable, thread-local handle.

Everything that is not the drive loop goes through this: spawn, udp, timer, and run for MoQ drivers. !Send, like everything the worker owns.

Implementations

impl Handle

pub fn metrics(&self) -> Metrics

This worker’s counters, readable from any thread.

pub fn spawn(&self, future: impl Future<Output = ()> + 'static)

Run a !Send future on this worker until completion.

If the worker has already been dropped the future is dropped instead of running, like a task spawned on a shut-down runtime.

pub fn udp( &self, socket: impl Into<Bound>, config: Config, ) -> Result<Socket, Error>

Drive socket through this worker’s ring.

The caller configures and binds the socket (options, addresses); this takes over receive and send. config picks the batching mechanisms.

The socket is what names this worker from here on: an Endpoint built on it runs its tasks here, whichever thread’s handle built it. A member of a steered reuseport group (moq_sock::shard::Socket) brings its slot along, so the connection ids issued through it steer back to this socket.

impl Handle

pub fn timer(&self) -> Timer

Allocate a disarmed timer on this worker.

pub async fn run<D: Driver>(&self, driver: D) -> Error

Run a MoQ driver with this worker’s timer and monotonic clock, resolving with its terminal error.

Trait Implementations

impl Clone for Handle

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Handle

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

Formats the value using the given formatter.