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.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/channel/routes/test/on_send.rs b/src/channel/routes/test/on_send.rs
index 20ae016..233518b 100644
--- a/src/channel/routes/test/on_send.rs
+++ b/src/channel/routes/test/on_send.rs
@@ -41,12 +41,12 @@ async fn messages_in_order() {
// Verify the semantics
- let subscribed_at = fixtures::now();
let events = app
.events()
- .subscribe(&subscribed_at, types::ResumePoint::default())
+ .subscribe(types::ResumePoint::default())
.await
.expect("subscribing to a valid channel")
+ .filter(fixtures::filter::messages())
.take(requests.len());
let events = events.collect::<Vec<_>>().immediately().await;