Code organization changes considered during implementation of vector-of-sequence-numbers stream resume.

1 files changed, 6 insertions, 5 deletions

diff --git a/src/channel/routes/test/on_send.rs b/src/channel/routes/test/on_send.rs
index eab7c32..6690374 100644
--- a/src/channel/routes/test/on_send.rs
+++ b/src/channel/routes/test/on_send.rs
@@ -5,7 +5,8 @@ use axum::{
 use futures::stream::StreamExt;
 
 use crate::{
-    channel::{app, routes},
+    channel::routes,
+    events::app,
     repo::channel,
     test::fixtures::{self, future::Immediately as _},
 };
@@ -42,8 +43,8 @@ async fn channel_exists() {
 
     let subscribed_at = fixtures::now();
     let mut events = app
-        .channels()
-        .events(&channel.id, &subscribed_at, None)
+        .events()
+        .subscribe(&channel.id, &subscribed_at, None)
         .await
         .expect("subscribing to a valid channel");
 
@@ -99,8 +100,8 @@ async fn messages_in_order() {
 
     let subscribed_at = fixtures::now();
     let events = app
-        .channels()
-        .events(&channel.id, &subscribed_at, None)
+        .events()
+        .subscribe(&channel.id, &subscribed_at, None)
         .await
         .expect("subscribing to a valid channel")
         .take(requests.len());