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.rs10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/channel/routes/test/on_send.rs b/src/channel/routes/test/on_send.rs
index 3297093..d2acc48 100644
--- a/src/channel/routes/test/on_send.rs
+++ b/src/channel/routes/test/on_send.rs
@@ -4,8 +4,8 @@ use futures::stream::StreamExt;
use crate::{
channel,
channel::routes,
- event,
- message::app::SendError,
+ event::{self, Sequenced},
+ message::{self, app::SendError},
test::fixtures::{self, future::Immediately as _},
};
@@ -53,10 +53,10 @@ async fn messages_in_order() {
let events = events.collect::<Vec<_>>().immediately().await;
for ((sent_at, message), event) in requests.into_iter().zip(events) {
- assert_eq!(*sent_at, event.instant.at);
+ assert_eq!(*sent_at, event.at());
assert!(matches!(
- event.kind,
- event::Kind::MessageSent(event)
+ event,
+ event::Event::Message(message::Event::Sent(event))
if event.message.sender == sender
&& event.message.body == message
));