diff options
| author | Owen Jacobson <owen@grimoire.ca> | 2024-10-24 22:50:23 -0400 |
|---|---|---|
| committer | Owen Jacobson <owen@grimoire.ca> | 2024-10-24 22:50:23 -0400 |
| commit | eae0edb57e9ade7c73affb78baf2ae267b6290b8 (patch) | |
| tree | d26f6d32d055ebd8b8f2d6a4b37e3e4bc58522a9 /src/event/routes/test/message.rs | |
| parent | 0bb17bd01640492db2685e67bacac12dd54a9f59 (diff) | |
Consolidate test helper event functions
Diffstat (limited to 'src/event/routes/test/message.rs')
| -rw-r--r-- | src/event/routes/test/message.rs | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/src/event/routes/test/message.rs b/src/event/routes/test/message.rs index 9bbbc7d..df42a89 100644 --- a/src/event/routes/test/message.rs +++ b/src/event/routes/test/message.rs @@ -42,8 +42,8 @@ async fn sending() { // Verify that an event is delivered let _ = events - .filter_map(fixtures::message::events) - .filter_map(fixtures::message::sent) + .filter_map(fixtures::event::message) + .filter_map(fixtures::event::message::sent) .filter(|event| future::ready(event.message == message)) .next() .immediately() @@ -83,8 +83,8 @@ async fn previously_sent() { // Verify that an event is delivered let _ = events - .filter_map(fixtures::message::events) - .filter_map(fixtures::message::sent) + .filter_map(fixtures::event::message) + .filter_map(fixtures::event::message::sent) .filter(|event| future::ready(event.message == message)) .next() .immediately() @@ -124,8 +124,8 @@ async fn sent_in_multiple_channels() { // Verify the structure of the response. let events = events - .filter_map(fixtures::message::events) - .filter_map(fixtures::message::sent) + .filter_map(fixtures::event::message) + .filter_map(fixtures::event::message::sent) .take(messages.len()) .collect::<Vec<_>>() .immediately() @@ -160,8 +160,8 @@ async fn sent_sequentially() { // Verify the expected events in the expected order let mut events = events - .filter_map(fixtures::message::events) - .filter_map(fixtures::message::sent) + .filter_map(fixtures::event::message) + .filter_map(fixtures::event::message::sent) .filter(|event| future::ready(messages.iter().any(|message| &event.message == message))); for message in &messages { @@ -201,8 +201,8 @@ async fn expiring() { // Check for expiry event let _ = events - .filter_map(fixtures::message::events) - .filter_map(fixtures::message::deleted) + .filter_map(fixtures::event::message) + .filter_map(fixtures::event::message::deleted) .filter(|event| future::ready(event.id == message.id)) .next() .immediately() @@ -236,8 +236,8 @@ async fn previously_expired() { // Check for expiry event let _ = events - .filter_map(fixtures::message::events) - .filter_map(fixtures::message::deleted) + .filter_map(fixtures::event::message) + .filter_map(fixtures::event::message::deleted) .filter(|event| future::ready(event.id == message.id)) .next() .immediately() @@ -271,8 +271,8 @@ async fn deleting() { // Check for delete event let _ = events - .filter_map(fixtures::message::events) - .filter_map(fixtures::message::deleted) + .filter_map(fixtures::event::message) + .filter_map(fixtures::event::message::deleted) .filter(|event| future::ready(event.id == message.id)) .next() .immediately() @@ -306,8 +306,8 @@ async fn previously_deleted() { // Check for delete event let _ = events - .filter_map(fixtures::message::events) - .filter_map(fixtures::message::deleted) + .filter_map(fixtures::event::message) + .filter_map(fixtures::event::message::deleted) .filter(|event| future::ready(event.id == message.id)) .next() .immediately() |