summaryrefslogtreecommitdiff
path: root/src/channel/routes/test/on_send.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/channel/routes/test/on_send.rs')
-rw-r--r--src/channel/routes/test/on_send.rs13
1 files changed, 7 insertions, 6 deletions
diff --git a/src/channel/routes/test/on_send.rs b/src/channel/routes/test/on_send.rs
index 33ec3b7..1027b29 100644
--- a/src/channel/routes/test/on_send.rs
+++ b/src/channel/routes/test/on_send.rs
@@ -4,7 +4,8 @@ use futures::stream::StreamExt;
use crate::{
channel,
channel::routes,
- event::{app, types},
+ event,
+ message::app,
test::fixtures::{self, future::Immediately as _},
};
@@ -54,10 +55,10 @@ async fn messages_in_order() {
for ((sent_at, message), event) in requests.into_iter().zip(events) {
assert_eq!(*sent_at, event.instant.at);
assert!(matches!(
- event.data,
- types::ChannelEventData::Message(event_message)
- if event_message.sender == sender
- && event_message.message.body == message
+ event.kind,
+ event::Kind::MessageSent(event)
+ if event.message.sender == sender
+ && event.message.body == message
));
}
}
@@ -90,6 +91,6 @@ async fn nonexistent_channel() {
assert!(matches!(
error,
- app::EventsError::ChannelNotFound(error_channel) if channel == error_channel
+ app::Error::ChannelNotFound(error_channel) if channel == error_channel
));
}