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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
use std::future::{self, Ready};
use crate::{event::Event, test::fixtures::event};
pub fn channel(event: Event) -> Ready<Option<crate::channel::Event>> {
future::ready(event::channel(event))
}
pub fn message(event: Event) -> Ready<Option<crate::message::Event>> {
future::ready(event::message(event))
}
pub fn user(event: Event) -> Ready<Option<crate::user::Event>> {
future::ready(event::user(event))
}
pub mod channel {
use std::future::{self, Ready};
use crate::{
channel::{Event, event},
test::fixtures::event::channel,
};
pub fn created(event: Event) -> Ready<Option<event::Created>> {
future::ready(channel::created(event))
}
pub fn deleted(event: Event) -> Ready<Option<event::Deleted>> {
future::ready(channel::deleted(event))
}
}
pub mod message {
use std::future::{self, Ready};
use crate::{
message::{Event, event},
test::fixtures::event::message,
};
pub fn sent(event: Event) -> Ready<Option<event::Sent>> {
future::ready(message::sent(event))
}
pub fn deleted(event: Event) -> future::Ready<Option<event::Deleted>> {
future::ready(message::deleted(event))
}
}
pub mod user {
use std::future::{self, Ready};
use crate::{
test::fixtures::event::user,
user::{Event, event},
};
pub fn created(event: Event) -> Ready<Option<event::Created>> {
future::ready(user::created(event))
}
}
|
