From 155f6f2556b21e6b25afe096b19adcde1255c598 Mon Sep 17 00:00:00 2001
From: Owen Jacobson <owen@grimoire.ca>
Date: Fri, 27 Sep 2024 23:46:55 -0400
Subject: Expire channels, too.

---
 src/channel/routes/test/on_create.rs | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

(limited to 'src/channel/routes/test/on_create.rs')

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]
-- 
cgit v1.2.3