Expire channels, too.

1 files changed, 7 insertions, 3 deletions

diff --git a/src/channel/routes/test/on_create.rs b/src/channel/routes/test/on_create.rs
index 5e62d7f..e2610a5 100644
--- a/src/channel/routes/test/on_create.rs
+++ b/src/channel/routes/test/on_create.rs
@@ -1,5 +1,5 @@
 use axum::extract::{Json, State};
-use futures::{future, stream::StreamExt as _};
+use futures::stream::StreamExt as _;
 
 use crate::{
     channel::{app, routes},
@@ -41,7 +41,7 @@ async fn new_channel() {
         .subscribe(types::ResumePoint::default())
         .await
         .expect("subscribing never fails")
-        .filter(|types::ResumableEvent(_, event)| future::ready(event.channel == response_channel));
+        .filter(fixtures::filter::created());
 
     let types::ResumableEvent(_, event) = events
         .next()
@@ -50,7 +50,11 @@ async fn new_channel() {
         .expect("creation event published");
 
     assert_eq!(types::Sequence::default(), event.sequence);
-    assert_eq!(types::ChannelEventData::Created, event.data);
+    assert!(matches!(
+        event.data,
+        types::ChannelEventData::Created(event)
+            if event.channel == response_channel
+    ));
 }
 
 #[tokio::test]