Struct LegacyBatchValuesFirstSerialized

pub struct LegacyBatchValuesFirstSerialized<'f, T> { /* private fields */ }

Allows reusing already-serialized first value

We’ll need to build a LegacySerializedValues for the first ~ValueList of a batch to figure out the shard (#448). Once that is done, we can use that instead of re-serializing.

This struct implements both BatchValues and BatchValuesIterator for that purpose

Implementations

impl<'f, T: LegacyBatchValues> LegacyBatchValuesFirstSerialized<'f, T>

pub fn new( batch_values: T, already_serialized_first: Option<&'f LegacySerializedValues>, ) -> Self

Trait Implementations

impl<'f, BV: LegacyBatchValues> LegacyBatchValues for LegacyBatchValuesFirstSerialized<'f, BV>

type LegacyBatchValuesIter<'r> = LegacyBatchValuesFirstSerialized<'f, <BV as LegacyBatchValues>::LegacyBatchValuesIter<'r>> where Self: 'r

For some unknown reason, this type, when not resolved to a concrete type for a given async function, cannot live across await boundaries while maintaining the corresponding future Send, unless 'r: 'static

fn batch_values_iter(&self) -> Self::LegacyBatchValuesIter<'_>

impl<'a, 'f: 'a, IT: LegacyBatchValuesIterator<'a>> LegacyBatchValuesIterator<'a> for LegacyBatchValuesFirstSerialized<'f, IT>

fn next_serialized(&mut self) -> Option<SerializedResult<'a>>

fn write_next_to_request( &mut self, buf: &mut impl BufMut, ) -> Option<Result<(), SerializeValuesError>>

fn skip_next(&mut self) -> Option<()>

fn count(self) -> usize

where Self: Sized,