Struct Stream 

pub struct Stream { /* private fields */ }

A target rendered block by block off one table, reading @notes, the sum of the terms added. A change builds only what it changed or newly reads; the rest stays as it stood.

Implementations

impl Stream

pub async fn open<B>( graph: &Graph, target: &Expr, config: StreamConfig, tier: &Tier<B>, ) -> Result<Stream, EngineError>

where B: Backend,

pub fn graph(&self) -> &Graph

pub fn read(&mut self, at: i64, n: usize) -> Result<Option<Block>, EngineError>

n samples from at, None past the end. An at behind is refused; one ahead skips there, computing through the span, or, live, as go_live says.

pub fn go_live(&mut self)

An edited node with no state, or one a read skips past, starts silent, never computing its past, named in dropped; a formula reads on exactly.

pub fn dropped(&self) -> Vec<&str>

The latest nodes a live edit started silent, of counts().dropped.

pub fn counts(&self) -> Counts

pub fn evaluated(&self, node: &str) -> Vec<Extent>

Every segment of its own clock the stream computed of node’s value, in order.

pub fn pruned(&self) -> Pruned

pub fn landed(&self, handle: Handle) -> Option<i64>

pub fn position(&self) -> i64

pub fn work(&self) -> Work

pub fn stats(&self) -> CacheStats

pub fn held_bytes(&self) -> usize

The bytes its values hold, samples and state.

pub fn end(&self) -> Option<i64>

pub fn width(&self) -> usize

pub fn config(&self) -> &StreamConfig