Struct RegisteredPullConsumer 

pub struct RegisteredPullConsumer { /* private fields */ }

A consumer registration that has been recorded in a crate::kernel::subcontext::SubcontextBuilder.

Wraps an Arc<dyn PullConsumer> so consumers can be cheaply shared between the artifact and the spawned kernel without trait-object cloning. The host’s fixture adapter owns the seal step; this type only records the consumer for later inspection.

Implementations

impl RegisteredPullConsumer

pub fn new(consumer: Arc<dyn PullConsumer>) -> Self

A registered consumer wrapping consumer.

pub fn names(&self) -> &[String]

Inspect the names this consumer requested. Used by the activity-side adapter at seal time and by Phase 1 tests to verify the registration round-trip.

pub fn label(&self) -> &str

The consumer’s diagnostic label.

pub fn as_dyn(&self) -> &dyn PullConsumer

Borrow the underlying trait object — the activity-side adapter uses this to dispatch to consumer-specific configuration once it has the kernel program in hand.

Trait Implementations

impl Clone for RegisteredPullConsumer

fn clone(&self) -> RegisteredPullConsumer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RegisteredPullConsumer

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

Formats the value using the given formatter.