From af7ece7dd5433051d67526ae15ad64f0f5b5e568 Mon Sep 17 00:00:00 2001 From: Owen Jacobson Date: Wed, 25 Sep 2024 01:05:38 -0400 Subject: Code organization changes considered during implementation of vector-of-sequence-numbers stream resume. --- src/channel/routes/test/on_send.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) (limited to 'src/channel/routes/test') 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()); -- cgit v1.2.3