fix: streams cancellation error (#18)

Co-authored-by: segfaultdoctor
jito-labs · Jul 2, 2024 · 77c9d8f · 77c9d8f
1 parent 2063aa6
commit 77c9d8f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/sdk/block-engine/searcher.ts b/src/sdk/block-engine/searcher.ts
@@ -147,7 +147,7 @@ export class SearcherClient {
       errorCallback(new Error(`Stream error: ${e.message}`));
     });
 
-    return stream.cancel;
+    return () => stream.cancel();
   }
 
   /**

diff --git a/src/sdk/geyser/geyser.ts b/src/sdk/geyser/geyser.ts
@@ -71,7 +71,7 @@ export class GeyserClient {
       errorCallback(new Error(`Stream error: ${e.message}`))
     );
 
-    return stream.cancel;
+    return () => stream.cancel();
   }
 
   /**
@@ -102,7 +102,7 @@ export class GeyserClient {
       errorCallback(new Error(`Stream error: ${e.message}`))
     );
 
-    return stream.cancel;
+    return () => stream.cancel();
   }
 
   /**
@@ -130,7 +130,7 @@ export class GeyserClient {
       errorCallback(new Error(`Stream error: ${e.message}`))
     );
 
-    return stream.cancel;
+    return () => stream.cancel();
   }
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -147,7 +147,7 @@ export class SearcherClient { @@
           errorCallback(new Error(`Stream error: ${e.message}`));
         });
-        return stream.cancel;
+        return () => stream.cancel();
       }
       /**
@@ Expand Down @@