Struct StreamBatch 

pub struct StreamBatch {
    pub run: RunId,
    pub from: u64,
    pub next: u64,
    pub chunks: Vec<Chunk>,
    pub end: Option<StreamEnd>,
}

One read’s answer: the durable chunks from from on, and the end once the reader has every chunk.

Fields

run: RunId

The run the stream belongs to. A reader passes it back to keep reading that run when its workflow ID moves on to another.

from: u64

next: u64

The offset to read from next.

chunks: Vec<Chunk>

end: Option<StreamEnd>

Implementations

impl StreamBatch

pub fn parse(bytes: &[u8]) -> Result<Self>

Decodes a read’s answer (JSON, as every SDK and the server get it).

pub fn from_json(v: &Value) -> Result<Self>

Self::parse from a JSON value.

Trait Implementations

impl Clone for StreamBatch

fn clone(&self) -> StreamBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamBatch

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

Formats the value using the given formatter.

impl PartialEq for StreamBatch

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for StreamBatch