chore: Reduce channel bounds to 0

Satellite-im · Oct 25, 2023 · a04000e · a04000e
1 parent 042f482
commit a04000e
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/extensions/warp-ipfs/src/store/document/cache.rs b/extensions/warp-ipfs/src/store/document/cache.rs
@@ -57,7 +57,7 @@ impl IdentityCache {
             None => None,
         };
 
-        let (tx, rx) = futures::channel::mpsc::channel(1);
+        let (tx, rx) = futures::channel::mpsc::channel(0);
 
         let mut task = IdentityCacheTask {
             ipfs: ipfs.clone(),

diff --git a/extensions/warp-ipfs/src/store/document/conversation.rs b/extensions/warp-ipfs/src/store/document/conversation.rs
@@ -89,7 +89,7 @@ impl Conversations {
             None => None,
         };
 
-        let (tx, rx) = futures::channel::mpsc::channel(1);
+        let (tx, rx) = futures::channel::mpsc::channel(0);
 
         let mut task = ConversationTask {
             ipfs: ipfs.clone(),

diff --git a/extensions/warp-ipfs/src/store/document/root.rs b/extensions/warp-ipfs/src/store/document/root.rs
@@ -121,7 +121,7 @@ impl RootDocumentMap {
             None => None,
         };
 
-        let (tx, rx) = futures::channel::mpsc::channel(1);
+        let (tx, rx) = futures::channel::mpsc::channel(0);
 
         let mut task = RootDocumentTask {
             ipfs: ipfs.clone(),