Struct BufferedRawJsonFlashblocksAdapter 

pub struct BufferedRawJsonFlashblocksAdapter { /* private fields */ }

Provider-free adapter that tolerates one briefly reordered JSON Flashblock.

This wrapper preserves RawJsonFlashblocksAdapter’s immediate behavior except for one narrow case: when an active payload receives exactly expected_index + 1, it retains that one parsed frame until the missing index arrives or the caller-owned deadline expires. It performs no I/O, starts no timer, mutates no canonical state, and grants no execution or trigger authority. Applications must schedule their own timer from Self::buffered_gap and call Self::expire_gap_at.

Implementations

impl BufferedRawJsonFlashblocksAdapter

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

Construct a bounded one-frame reorder adapter.

gap_timeout_millis must be in the reviewed inclusive range 300..=500. The caller supplies timestamps from one monotonic clock.

Errors

Returns RawJsonFlashblocksError::InvalidLimits for an unreviewed gap timeout or invalid raw-frame resource limits.

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

Provider generation attached to normalized snapshots and invalidations.

pub const fn limits(&self) -> RawJsonFlashblocksLimits

Resource limits applied to immediate and buffered frames.

pub fn buffered_gap(&self) -> Option<(u64, u64, u64)>

Return (missing_index, buffered_index, expires_at_millis) when a caller-owned gap timer is required.

pub fn ingest_json_at( &mut self, frame: &[u8], now_millis: u64, ) -> Result<Vec<FlashblockUpdate>, RawJsonFlashblocksError>

Decode one application-data frame at a caller-supplied monotonic time.

The returned vector has at most two entries. Two snapshots are returned only when the missing index and the retained next index are validated atomically and drained in order. Errors preserve the last successfully published state and any pending gap for explicit caller reset.

Errors

Returns RawJsonFlashblocksError immediately for malformed, unsupported, or resource-exhausting input.

pub fn ingest_json_timed_at( &mut self, frame: &[u8], now_millis: u64, ) -> Result<Vec<TimedFlashblockUpdate>, RawJsonFlashblocksError>

Decode one application-data frame while retaining the original caller-clock arrival for every emitted update.

When a future frame is buffered across a one-index gap, its eventual output retains the timestamp from the call that first supplied that frame, not the later gap-closing call. This method is provider-free and starts no timer.

Errors

Returns RawJsonFlashblocksError under the same conditions as Self::ingest_json_at.

pub fn expire_gap_at(&mut self, now_millis: u64) -> Option<FlashblockUpdate>

Expire a buffered gap using the same caller-owned monotonic clock.

At or after the deadline this emits one typed IndexGap invalidation, clears the retained frame, and ignores the late remainder of that payload until a new payload begins.

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

Revoke the active payload and clear any retained reorder frame.

A rejected source transition preserves both the active state and buffer.

Errors

Returns RawJsonFlashblocksError::InvalidSourceTransition under the same conditions as RawJsonFlashblocksAdapter::reset.

Trait Implementations

impl Clone for BufferedRawJsonFlashblocksAdapter

fn clone(&self) -> BufferedRawJsonFlashblocksAdapter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BufferedRawJsonFlashblocksAdapter

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

Formats the value using the given formatter.