futures_rx/
lib.rs

1pub mod stream;
2pub mod stream_ext;
3pub mod subject;
4
5pub use crate::{
6    stream::controller::*,
7    stream::event::*,
8    stream::event_lite::*,
9    stream::notification::*,
10    stream::observable::*,
11    stream::rx::combine_latest::*,
12    stream::rx::zip::*,
13    stream_ext::RxExt,
14    subject::{
15        Subject,
16        {behavior_subject::*, publish_subject::*, replay_subject::*},
17    },
18};
19
20pub mod prelude {
21    pub use crate::{
22        stream::event::*,
23        stream::event_lite::*,
24        stream::notification::*,
25        stream::rx::combine_latest::*,
26        stream::rx::zip::*,
27        stream_ext::RxExt,
28        subject::{
29            Subject,
30            {behavior_subject::*, publish_subject::*, replay_subject::*},
31        },
32    };
33}