update patch-db (#1831)

Start9Labs · Sep 26, 2022 · 18336e4 · 18336e4
1 parent abf297d
commit 18336e4
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 76 deletions.
diff --git a/backend/Cargo.lock b/backend/Cargo.lock
diff --git a/backend/src/db/mod.rs b/backend/src/db/mod.rs
@@ -77,7 +77,7 @@ async fn subscribe_to_session_kill(
 async fn deal_with_messages(
     _has_valid_authentication: HasValidSession,
     mut kill: oneshot::Receiver<()>,
-    sub: patch_db::Subscriber,
+    mut sub: patch_db::Subscriber,
     mut stream: WebSocketStream<Upgraded>,
 ) -> Result<(), Error> {
     loop {
@@ -93,7 +93,7 @@ async fn deal_with_messages(
                     .with_kind(crate::ErrorKind::Network)?;
                 return Ok(())
             }
-            new_rev = sub.recv_async().fuse() => {
+            new_rev = sub.recv().fuse() => {
                 let rev = new_rev.expect("UNREACHABLE: patch-db is dropped");
                 stream
                     .send(Message::Text(serde_json::to_string(&rev).with_kind(crate::ErrorKind::Serialization)?))

diff --git a/libs/Cargo.lock b/libs/Cargo.lock
diff --git a/patch-db b/patch-db
+0 −1		patch-db/Cargo.toml
+1 −12		patch-db/src/handle.rs
+3 −8		patch-db/src/lib.rs
+14 −18		patch-db/src/store.rs
+35 −0		patch-db/src/subscriber.rs
+3 −4		patch-db/src/test.rs
+5 −9		patch-db/src/transaction.rs