Enum BlockingRequest 

pub enum BlockingRequest<'a> {
    NewChan(Option<usize>),
    Send(ChanId, RtPayload),
    TrySend(ChanId, RtPayload),
    Recv(ChanId),
    TryRecv(ChanId),
    Select(Vec<SelectArm>),
    Sleep(u64),
    Spawn(Box<dyn Task<'a> + 'a>),
    Await(TaskId),
    Abort(TaskId),
    Close(ChanId),
}

A blocking (or non-blocking-but-scheduler-routed) request the interpreter hands to the scheduler.

Variants

NewChan(Option<usize>)

Create a channel of the given capacity (None = config default).

Send(ChanId, RtPayload)

Send a value into a channel (blocks if full).

TrySend(ChanId, RtPayload)

Non-blocking send; resume with Payload(Bool(success)).

Recv(ChanId)

Receive a value from a channel (blocks if empty).

TryRecv(ChanId)

Non-blocking receive; resume with the value, or Payload(Nothing) if empty.

Select(Vec<SelectArm>)

Await the first ready arm of a select.

Sleep(u64)

Sleep for some logical ticks.

Spawn(Box<dyn Task<'a> + 'a>)

Spawn a child task; resume with its TaskId.

Await(TaskId)

Await a task’s completion; resume with its result payload.

Abort(TaskId)

Abort a task.

Close(ChanId)

Close a channel.