Track event sequences globally, not per channel.

Per-channel event sequences were a cute idea, but it made reasoning about event resumption much, much harder (case in point: recovering the order of events in a partially-ordered collection is quadratic, since it's basically graph sort). The minor overhead of a global sequence number is likely tolerable, and this simplifies both the API and the internals.

2 files changed, 4 insertions, 5 deletions

diff --git a/src/channel/routes/test/on_create.rs b/src/channel/routes/test/on_create.rs
index e2610a5..5deb88a 100644
--- a/src/channel/routes/test/on_create.rs
+++ b/src/channel/routes/test/on_create.rs
@@ -38,18 +38,17 @@ async fn new_channel() {
 
     let mut events = app
         .events()
-        .subscribe(types::ResumePoint::default())
+        .subscribe(None)
         .await
         .expect("subscribing never fails")
         .filter(fixtures::filter::created());
 
-    let types::ResumableEvent(_, event) = events
+    let event = events
         .next()
         .immediately()
         .await
         .expect("creation event published");
 
-    assert_eq!(types::Sequence::default(), event.sequence);
     assert!(matches!(
         event.data,
         types::ChannelEventData::Created(event)
diff --git a/src/channel/routes/test/on_send.rs b/src/channel/routes/test/on_send.rs
index 233518b..d37ed21 100644
--- a/src/channel/routes/test/on_send.rs
+++ b/src/channel/routes/test/on_send.rs
@@ -43,7 +43,7 @@ async fn messages_in_order() {
 
     let events = app
         .events()
-        .subscribe(types::ResumePoint::default())
+        .subscribe(None)
         .await
         .expect("subscribing to a valid channel")
         .filter(fixtures::filter::messages())
@@ -51,7 +51,7 @@ async fn messages_in_order() {
 
     let events = events.collect::<Vec<_>>().immediately().await;
 
-    for ((sent_at, message), types::ResumableEvent(_, event)) in requests.into_iter().zip(events) {
+    for ((sent_at, message), event) in requests.into_iter().zip(events) {
         assert_eq!(*sent_at, event.at);
         assert!(matches!(
             event.data,