Struct StreamRecord 

pub struct StreamRecord { /* private fields */ }

A completion stream’s items read back from their serialized form, in an order the writer could have produced: each part starts once, at a position no part took before, grows only while open and with its own kind of fragment, and ends once. Positions follow the order provider items opened, so a dropped item leaves a gap. Unmodeled payloads may come anywhere.

Implementations

impl StreamRecord

pub fn parse(value: Value) -> Result<Self, SequenceError>

Read a serialized item sequence, refusing one the writer could not have produced. Every part must have ended.

pub fn parse_prefix(value: Value) -> Result<Self, SequenceError>

Self::parse for a stream that stopped early (an error or a cancellation): parts may still be open at its end.

pub fn push(&mut self, item: Item<StreamEvent>) -> Result<(), SequenceError>

Append the next item a stream yielded, refusing one the writer could not have produced after the items so far.

pub fn from_items(items: Vec<Item<StreamEvent>>) -> Result<Self, SequenceError>

Items a stream yielded, checked as Self::push checks them: a stream that stopped early may leave parts open.

pub fn len(&self) -> usize

The number of items.

pub fn is_empty(&self) -> bool

Whether there are no items.

pub fn items(&self) -> &[Item<StreamEvent>]

The items, in order.

pub fn into_items(self) -> Vec<Item<StreamEvent>>

The items, in order.

pub fn events(&self) -> impl Iterator<Item = &StreamEvent>

The events, in order, without the unmodeled payloads.

Trait Implementations

impl Clone for StreamRecord

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamRecord

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

Formats the value using the given formatter.

impl Default for StreamRecord

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamRecord

Read as the item list it is, with no Value tree between.

fn deserialize<D: Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error>

Deserialize this value from the given Serde deserializer.

impl From<StreamRecord> for Vec<Item<StreamEvent>>

fn from(transcript: StreamRecord) -> Self

Converts to this type from the input type.

impl PartialEq for StreamRecord

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for StreamRecord

fn serialize<S: Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error>

Serialize this value into the given Serde serializer.