Struct StagedInputBuffer 

pub struct StagedInputBuffer { /* private fields */ }

A wrapper around a StagedBuffers that implements the InputBuffer trait.

The StagedBuffers trait is similar to InputBuffer in that it supports flushing a set of tuples to the circuit. Unlike InputBuffer, it doesn’t support returning its size as a BufferSize. It also doesn’t support hashing and taking a subset of records.

This wrapper adds the former by storing BufferSize collected from InputBuffers used to create the StagedBuffers.

hash() and take_some() methods are unimplemented. Therefore this wrapper can only be safely used in contexts where these methods are not needed.

Implementations

impl StagedInputBuffer

pub fn new(buffer: Box<dyn StagedBuffers>, size: BufferSize) -> Self

Trait Implementations

impl InputBuffer for StagedInputBuffer

fn flush(&mut self)

Pushes all of the records into the circuit input handle, and discards those records.

fn len(&self) -> BufferSize

Returns the number of buffered records and bytes.

fn hash(&self, _hasher: &mut dyn Hasher)

Hashes the records in the input buffer into hasher, in order. This is used to ensure that input data remains the same for replay, so, for equal data, it should remain the same from one program run to the next. Data might be divided into InputBuffers differently from one run to the next, so the data fed into hasher should be the same if, for example, records 0..10 then 10..20 are fed in one run and 0..5, 5..15, 15..20 in another.

fn take_some(&mut self, _n: usize) -> Option<Box<dyn InputBuffer>>

Removes the first n records from this input buffer and returns a new InputBuffer that holds them. If fewer than n records are available, returns all of them. May return None if this input buffer is empty (or if n is 0).

fn is_empty(&self) -> bool

fn take_all(&mut self) -> Option<Box<dyn InputBuffer>>