2 files changed, 3 insertions, 3 deletions
diff --git a/src/channel/routes/test/on_create.rs b/src/channel/routes/test/on_create.rs
index bb6697f..5e62d7f 100644
--- a/src/channel/routes/test/on_create.rs
+++ b/src/channel/routes/test/on_create.rs
@@ -38,7 +38,7 @@ async fn new_channel() {
 
     let mut events = app
         .events()
-        .subscribe(&fixtures::now(), types::ResumePoint::default())
+        .subscribe(types::ResumePoint::default())
         .await
         .expect("subscribing never fails")
         .filter(|types::ResumableEvent(_, event)| future::ready(event.channel == response_channel));
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;