summaryrefslogtreecommitdiff
path: root/src/channel/routes/test
diff options
context:
space:
mode:
Diffstat (limited to 'src/channel/routes/test')
-rw-r--r--src/channel/routes/test/on_send.rs11
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());