hyphae 0.6.2

Reactive cells and runtime primitives for rship
Documentation
// Re-export base traits for use by operator modules
pub(crate) use super::{CellValue, Gettable, Watchable};

mod audit;
mod backpressure;
mod buffer_count;
mod buffer_time;
mod cold;
mod concat;
mod debounce;
mod deduped;
mod delay;
mod distinct;
mod distinct_until_changed_by;
mod filter;
mod finalize;
mod first;
mod join;
mod join_vec;
mod last;
mod map;
mod merge;
mod merge_map;
mod pairwise;
#[cfg(not(target_arch = "wasm32"))]
mod parallel;
mod result_ext;
mod retry;
mod sample;
mod scan;
mod skip;
mod skip_while;
mod state_transition;
mod switch_map;
mod take;
mod take_until;
mod take_while;
mod tap;
mod throttle;
mod timeout;
mod try_map;
mod window;
mod with_latest_from;
mod zip;

pub use audit::AuditExt;
pub use backpressure::BackpressureExt;
pub use buffer_count::BufferCountExt;
pub use buffer_time::BufferTimeExt;
pub use cold::ColdExt;
pub use concat::ConcatExt;
pub use debounce::DebounceExt;
pub use deduped::DedupedExt;
pub use delay::DelayExt;
pub use distinct::DistinctExt;
pub use distinct_until_changed_by::DistinctUntilChangedByExt;
pub use filter::FilterExt;
pub use finalize::FinalizeExt;
pub use first::FirstExt;
pub use join::JoinExt;
pub use join_vec::join_vec;
pub use last::LastExt;
pub use map::MapExt;
pub use merge::MergeExt;
pub use merge_map::MergeMapExt;
pub use pairwise::PairwiseExt;
#[cfg(not(target_arch = "wasm32"))]
pub use parallel::{ParallelCell, ParallelExt};
pub use result_ext::{CatchErrorExt, MapErrExt, MapOkExt, UnwrapOrExt};
pub use retry::RetryExt;
pub use sample::SampleExt;
pub use scan::ScanExt;
pub use skip::SkipExt;
pub use skip_while::SkipWhileExt;
pub use state_transition::{StateMachineBuilder, StateTransitionExt};
pub use switch_map::SwitchMapExt;
pub use take::TakeExt;
pub use take_until::TakeUntilExt;
pub use take_while::TakeWhileExt;
pub use tap::TapExt;
pub use throttle::ThrottleExt;
pub use timeout::TimeoutExt;
pub use try_map::TryMapExt;
pub use window::WindowExt;
pub use with_latest_from::WithLatestFromExt;
pub use zip::ZipExt;