Crate fluxion_core 

Re-exports

pub use self::cancellation_token::CancellationToken;

pub use self::fluxion::Fluxion;

pub use self::fluxion_error::FluxionError;

pub use self::fluxion_error::Result;

pub use self::fluxion_error::ResultExt;

pub use self::fluxion_task::FluxionTask;

pub use self::has_timestamp::HasTimestamp;

pub use self::into_stream::IntoStream;

pub use self::stream_item::StreamItem;

pub use self::subject_error::SubjectError;

pub use self::timestamped::Timestamped;

Modules

cancellation_token

Runtime-agnostic cancellation token.

fluxion

fluxion_error

Error types for Fluxion reactive streaming library

fluxion_mutex

Synchronization primitives that switch between parking_lot (std) and spin (no_std).

fluxion_task

Runtime-agnostic task spawning with cooperative cancellation.

has_timestamp

into_stream

stream_item

subject_error

timestamped