Struct Flow 

pub struct Flow {
    pub id: FlowId,
    pub vm: Vm,
    pub mailbox: Arc<Mailbox>,
    pub metrics: Arc<FlowMetrics>,
    pub restart_policy: RestartPolicy,
    pub pending_message: Option<Value>,
    pub last_receive_dest: Option<u8>,
    /* private fields */
}

A single flow: VM state, mailbox, and bookkeeping.

This is the unit of work moved by the scheduler — pushed onto worker deques, stolen, parked inside a Mailbox on Receive, or held by the timer wheel while sleeping. Flows talk only via Atomic Hops (crate::Value::Message on Send).

Fields

id: FlowId

vm: Vm

mailbox: Arc<Mailbox>

metrics: Arc<FlowMetrics>

restart_policy: RestartPolicy

pending_message: Option<Value>

Set by Mailbox::park when a hop wins the park race.

last_receive_dest: Option<u8>

Destination register of the most recent Receive / ReceiveTimeout.

Implementations

impl Flow

pub fn new( id: FlowId, vm: Vm, mailbox: Arc<Mailbox>, restart_policy: RestartPolicy, completion: Sender<FlowOutcome>, ) -> Self