Struct RawJsonFlashblocksAdapter 

pub struct RawJsonFlashblocksAdapter { /* private fields */ }

Stateful converter for receipt-enriched, indexed JSON Flashblock payloads.

Compatibility is defined by the accepted wire profile, not by chain id: payload_id, a monotonically increasing index, an index-zero base (or static) header, transaction deltas in diff.transactions, and an exact receipt map in metadata.receipts. Provider JSON-RPC subscription envelopes, receipt-less payloads, and binary SSZ frames are separate wire profiles and are not accepted by this adapter.

The adapter performs no I/O. The caller owns WebSocket control frames, authentication, timeouts, retry, backoff, and provider rotation. On source replacement or disconnect, call Self::reset and forward the returned invalidation before accepting updates from the new provider generation.

Implementations

impl RawJsonFlashblocksAdapter

pub fn new(provider: ProviderRef) -> Self

Construct an adapter with bounded production defaults.

pub fn with_limits( provider: ProviderRef, limits: RawJsonFlashblocksLimits, ) -> Result<Self, RawJsonFlashblocksError>

Construct an adapter with explicit resource bounds.

pub const fn provider(&self) -> &ProviderRef

Provider generation attached to newly normalized snapshots.

pub const fn limits(&self) -> RawJsonFlashblocksLimits

Resource limits applied by this adapter.

pub fn reset( &mut self, provider: ProviderRef, ) -> Result<Option<FlashblockUpdate>, RawJsonFlashblocksError>

Revoke the active payload and begin a caller-managed provider generation.

This method never reconnects, sleeps, or performs I/O. None means the prior source had no active payload to revoke.

Errors

Returns RawJsonFlashblocksError::InvalidSourceTransition when the endpoint identity changes or the generation does not increase. Rebuild the adapter and subscriber binding to select a different endpoint.

pub fn ingest_json( &mut self, frame: &[u8], ) -> Result<Option<FlashblockUpdate>, RawJsonFlashblocksError>

Decode and normalize one raw JSON application-data frame.

Ok(None) denotes an identical duplicate or a later delta from a generation already invalidated for continuity loss. Err leaves the last successfully published adapter state unchanged. A live caller that cannot prove an application-data error irrelevant must call Self::reset with a newer generation and forward the returned invalidation before accepting more frames.

Trait Implementations

impl Debug for RawJsonFlashblocksAdapter

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

Formats the value using the given formatter.