Struct ProducerNodeState 

pub struct ProducerNodeState {
    pub subs: Vec<Subscription>,
    pub op_state: Option<Box<dyn Any + Send + Sync>>,
}

Per-producer-node state owned by the ProducerBinding impl.

Holds upstream Subscriptions (auto-dropped on producer deactivation) plus an optional Box<dyn Any> slot for op-specific state shared across the build closure and its sink closures. (Most ops capture state via Arc<Mutex<...>> directly in closure captures; the op_state slot is reserved for ops that prefer trait-object storage.)

Fields

subs: Vec<Subscription>

Subscriptions to upstream sources, taken by ProducerCtx::subscribe_to. Dropped on producer deactivation.

op_state: Option<Box<dyn Any + Send + Sync>>

Optional op-specific scratch (rarely used; most ops capture state via closure).

Trait Implementations

impl Default for ProducerNodeState

fn default() -> ProducerNodeState

Returns the “default value” for a type.