ferroui-reactive 0.3.0

A port of Rx.NET (System.Reactive) for FerroUI: observable sequences, their operators, schedulers, disposables and subjects, independent of the user interface
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

//! The internal machinery of the operators (`System.Reactive` `Internal/`).

mod half_serializer;
mod priority_queue;
mod sink;
mod token_registration;

mod operator;
mod scheduled_observer;

pub(crate) use half_serializer::{HalfSerializedSink, HalfSerializer};
pub(crate) use operator::{impl_sink_dispose, unary, OperatorSink};
pub(crate) use priority_queue::PriorityQueue;
pub(crate) use scheduled_observer::{FastImmediateObserver, IScheduledObserver, ScheduledObserver};
pub(crate) use token_registration::TokenRegistration;
pub(crate) use sink::{nop_observer, subscribe_auto_detach, subscribe_basic, subscribe_sink, try_subscribe_auto_detach, AutoDetachObserver, NopObserver, SafeObserver, Sink};