futures_rx/
lib.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
pub mod stream;
pub mod stream_ext;
pub mod subject;

pub use crate::{
    stream::controller::*,
    stream::event::*,
    stream::notification::*,
    stream::observable::*,
    stream::rx::combine_latest::*,
    stream::rx::zip::*,
    stream_ext::RxExt,
    subject::{
        Subject,
        {behavior_subject::*, publish_subject::*, replay_subject::*},
    },
};

pub mod prelude {
    pub use crate::{
        stream::event::*,
        stream::notification::*,
        stream::rx::combine_latest::*,
        stream::rx::zip::*,
        stream_ext::RxExt,
        subject::{
            Subject,
            {behavior_subject::*, publish_subject::*, replay_subject::*},
        },
    };
}