update example

substreams-js · Dec 8, 2023 · 88d40b9 · 88d40b9
1 parent 3ee1e09
commit 88d40b9
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 2 deletions.
diff --git a/README.md b/README.md
@@ -88,5 +88,7 @@ emitter.on("fatalError", (error) => {
 console.log("✅ start");
 console.time("🆗 close");
 const cancel = emitter.start();
-// cancel() to exit substreams session
+
+// Cancel after 3 seconds
+setTimeout(cancel, 3000);
 ```
diff --git a/example.js b/example.js
@@ -52,6 +52,14 @@ emitter.on("anyMessage", (message, cursor, clock) => {
   console.dir(clock);
 });
 
+// End of Stream
+emitter.on("close", (error) => {
+  if (error) {
+    console.error(error);
+  }
+  console.timeEnd("🆗 close");
+});
+
 // Fatal Error
 emitter.on("fatalError", (error) => {
   console.error(error);
@@ -60,4 +68,6 @@ emitter.on("fatalError", (error) => {
 console.log("✅ start");
 console.time("🆗 close");
 const cancel = emitter.start();
-// cancel() to exit substreams session
+
+// Cancel after 3 seconds
+setTimeout(cancel, 3000);