Struct ProducerCtx 

pub struct ProducerCtx<'a> { /* private fields */ }

Context handed to a producer’s build closure on activation.

Provides:

• Self::node_id / Self::core — identity + Core access for sink callbacks that re-enter Core.
• Self::subscribe_to — subscribe to an upstream Core node; the resulting Subscription is auto-tracked under node_id in the binding’s producer storage and dropped on producer deactivation.

Implementations

impl<'a> ProducerCtx<'a>

pub fn new( node_id: NodeId, core: &'a Core, storage: &'a ProducerStorage, ) -> Self

Construct a new context for the binding’s invoke_fn dispatch to call build closures. Internal — bindings call this; user code receives the constructed ctx via the build closure’s arg.

pub fn node_id(&self) -> NodeId

The producer node’s id.

pub fn core(&self) -> &Core

The Core dispatcher. Sink closures use this to re-enter Core — core.emit(self.node_id(), h) to emit a value, etc.

pub fn subscribe_to(&self, source: NodeId, sink: Sink)

Subscribe sink to upstream source. The Subscription is auto-tracked under the producer’s node_id; on producer deactivation, the binding drops the storage entry, which drops the Subscription, which unsubscribes the sink.