Struct ReactiveInputBatch 

pub struct ReactiveInputBatch<N: Network = Ethereum> { /* private fields */ }

Batch of reactive input records.

Implementations

impl<N: Network> ReactiveInputBatch<N>

pub fn new(records: Vec<ReactiveInputRecord<N>>) -> Self

Create a batch from records.

pub fn with_chain_id(self, chain_id: u64) -> Self

Bind the complete batch, including control-only progress/finality, to a chain. Runtime ingestion rejects a different cache chain.

pub const fn chain_id(&self) -> Option<u64>

Authoritative batch chain identity, when supplied or unambiguously derived from its records.

pub fn with_delivery_token(self, token: SubscriberDeliveryToken) -> Self

Attach the subscriber-owned token committed after successful ingestion.

pub fn delivery_token(&self) -> Option<&SubscriberDeliveryToken>

Borrow the subscriber-owned delivery token, when present.

pub fn with_subscriber_checkpoint( self, checkpoint: SubscriberCheckpoint, ) -> Self

Attach provider-specific resume state included by this delivery.

pub fn subscriber_checkpoint(&self) -> Option<&SubscriberCheckpoint>

Borrow provider-specific resume state, when present.

pub fn with_payload_commitment( self, commitment: SubscriberPayloadCommitment, ) -> Self

Attach a commitment to the exact canonical wire payload represented by this batch.

pub const fn payload_commitment(&self) -> Option<&SubscriberPayloadCommitment>

Borrow the subscriber-supplied exact payload commitment, when present.

pub fn with_audience(self, audience: DeliveryAudience) -> Self

Restrict runtime routing to exact logical interest owners.

pub const fn audience(&self) -> &DeliveryAudience

Delivery audience captured by the subscriber.

pub fn from_scoped_records( records: impl IntoIterator<Item = (ReactiveInputRecord<N>, DeliveryAudience)>, ) -> Self

Create a batch whose records retain independent delivery audiences.

pub fn from_deliveries( deliveries: impl IntoIterator<Item = ReactiveInputDelivery<N>>, ) -> Self

Create a batch with independent routing and canonical provenance per record.

pub fn record_audience(&self, index: usize) -> Option<&DeliveryAudience>

Audience for the record at index.

pub fn with_delivery_scope(self, scope: DeliveryScope) -> Self

Set how every record in this batch participates in canonical state.

pub fn record_delivery_scope(&self, index: usize) -> Option<DeliveryScope>

Canonical-processing scope for the record at index.

pub fn with_chain_controls( self, controls: impl IntoIterator<Item = ChainControl>, ) -> Self

Attach ordered chain-lifecycle controls to this delivery.

A control-only batch must also call with_chain_id. When records are present, their unanimous chain id is derived by the constructor; a missing or cache-mismatched authoritative batch identity is rejected before any control mutates runtime state.

pub fn chain_controls(&self) -> &[ChainControl]

Ordered chain-lifecycle controls in this delivery.

pub fn records(&self) -> &[ReactiveInputRecord<N>]

Borrow the records in this batch.

pub fn into_records(self) -> Vec<ReactiveInputRecord<N>>

Consume the batch into only its input records.

This is intentionally lossy: it discards the authoritative batch chain identity, routing audiences, delivery scopes, ordered chain controls, acknowledgement tokens, and provider checkpoints. Adapters should use into_parts instead.

pub fn into_parts(self) -> ReactiveInputBatchParts<N>

Consume the batch without losing subscriber or chain-lifecycle metadata.

Trait Implementations

impl<N: Clone + Network> Clone for ReactiveInputBatch<N>

fn clone(&self) -> ReactiveInputBatch<N>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<N: Debug + Network> Debug for ReactiveInputBatch<N>

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

Formats the value using the given formatter.