Struct sodium::SodiumCtx

pub struct SodiumCtx {
    pub impl_: SodiumCtx,
}

A context object representing a specific instance of a Sodium system.

Fields

impl_: SodiumCtx

Implementations

impl SodiumCtx

pub fn new() -> SodiumCtx

Create a new Sodium FRP context.

pub fn new_cell<A: Clone + Send + 'static>(&self, a: A) -> Cell<A>

Create a new constant value Cell in this context.

pub fn new_stream<A: Clone + Send + 'static>(&self) -> Stream<A>

Create a new stream that will never fire in this context.

pub fn new_cell_sink<A: Clone + Send + 'static>(&self, a: A) -> CellSink<A>

Create a new CellSink for interfacing I/O and FRP.

pub fn new_stream_sink<A: Clone + Send + 'static>(&self) -> StreamSink<A>

Create a new StreamSink for interfacing I/O and FRP.

pub fn new_cell_loop<A: Clone + Send + 'static>(&self) -> CellLoop<A>

Create a new CellLoop to act as a forward reference for a Cell that will be created later.

pub fn new_stream_loop<A: Clone + Send + 'static>(&self) -> StreamLoop<A>

Create a new StreamLoop to act as a forward reference for a Stream that will be created later.

pub fn new_stream_sink_with_coalescer<A: Clone + Send + 'static, COALESCER: FnMut(&A, &A) -> A + Send + 'static>( &self, coalescer: COALESCER ) -> StreamSink<A>

Create a new StreamSink with a combining function that allows sending multiple event values per transaction.

pub fn transaction<R, K: FnOnce() -> R>(&self, k: K) -> R

Run the given function inside a single Sodium transaction, closing the transaction after the function returns.

pub fn new_transaction(&self) -> Transaction

Create a new scoped transaction object.

The Sodium transaction on this context will be held open until the returned Transaction is dropped or Transaction::close is called explicitly.

pub fn post<K: FnMut() + Send + 'static>(&self, k: K)

Execute the given code after the current transaction is closed, or immediately if there is no current transaction.

pub fn new_router<A, K>( &self, in_stream: &Stream<A>, selector: impl Fn(&A) -> Vec<K> + Send + Sync + 'static ) -> Router<A, K>

where A: Clone + Send + 'static, K: Send + Sync + Eq + Hash + 'static,

Create a new Router in this context.

Trait Implementations

impl Clone for SodiumCtx

fn clone(&self) -> SodiumCtx

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for SodiumCtx

fn default() -> SodiumCtx

Returns the “default value” for a type.