Struct Stream 

pub struct Stream { /* private fields */ }

A target rendered block by block off one table. The target may read @notes, the sum of the terms added under handles; an edit to it or to a term plays from the next block on. Opening and each edit look store up first, as a render through it does.

Implementations

impl Stream

pub async fn open( graph: &Graph, target: &Expr, config: StreamConfig, cache: Option<&Cache>, store: &impl Through, ) -> Result<Stream, EngineError>

pub async fn edit( &mut self, graph: &Graph, target: &Expr, store: &impl Through, ) -> Result<(), EngineError>

pub async fn add( &mut self, graph: &Graph, term: &Expr, store: &impl Through, ) -> Result<Handle, EngineError>

pub async fn replace( &mut self, graph: &Graph, __arg2: (Handle, &Expr), store: &impl Through, ) -> Result<bool, EngineError>

False, and nothing edited, where the stream no longer holds handle.

pub async fn remove( &mut self, handle: Handle, store: &impl Through, ) -> Result<bool, EngineError>

A sounding term is cut where the stream stands, so what it played stays what it was.

pub fn exprs(&self) -> impl Iterator<Item = &Expr>

pub fn next_block(&mut self) -> Result<Option<Block>, EngineError>

The next block, cut where the stream ends; None from there on.

pub fn go_live(&mut self)

An edited node with no state there starts silent, never computing its past.

pub fn dropped(&self) -> &[String]

Each node a live edit started silent.

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 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