docs: add missing semicolons to follower example code

Signed-off-by: Esteban Laver <[email protected]>

test/examples/src/features/js/startAndProcess.js

@@ -21,7 +21,7 @@ const client = CloudantV1.newInstance();
 // Start from a previously persisted seq
 // Normally this would be read by the app from persistent storage
 // e.g. previouslyPersistedSeq = yourAppPersistenceReadFunc()
-const previouslyPersistedSeq = '3-g1AG3...'
+const previouslyPersistedSeq = '3-g1AG3...';
 const changesParams = {
   db: 'example',
   since: previouslyPersistedSeq
@@ -35,10 +35,10 @@ const destinationStream = new Writable({
     // do something with change item
     console.log(changesItem.id);
     for (const change of changesItem.changes) {
-      console.log(change.rev)
+      console.log(change.rev);
     }
     // when change item processing is complete app can store seq
-    const seq = changesItem.seq
+    const seq = changesItem.seq;
     // write seq to persistent storage for use as since if required to resume later
     // e.g. yourAppPersistenceWriteFunc()
     callback();

test/examples/src/features/js/startOneOffAndProcess.js

@@ -21,7 +21,7 @@ const client = CloudantV1.newInstance();
 // Start from a previously persisted seq
 // Normally this would be read by the app from persistent storage
 // e.g. previouslyPersistedSeq = yourAppPersistenceReadFunc()
-const previouslyPersistedSeq = '3-g1AG3...'
+const previouslyPersistedSeq = '3-g1AG3...';
 const changesParams = {
   db: 'example',
   since: previouslyPersistedSeq
@@ -35,10 +35,10 @@ const destinationStream = new Writable({
     // do something with change item
     console.log(changesItem.id);
     for (const change of changesItem.changes) {
-      console.log(change.rev)
+      console.log(change.rev);
     }
     // when change item processing is complete app can store seq
-    const seq = changesItem.seq
+    const seq = changesItem.seq;
     // write seq to persistent storage for use as since if required to resume later
     // e.g. yourAppPersistenceWriteFunc()
     callback();
@@ -62,12 +62,12 @@ async function getChangesFromFollower(changesItemsStream) {
     // write seq to persistent storage for use as since
     console.log(changesItem.id);
     for (const change of changesItem.changes) {
-      console.log(change.rev)
+      console.log(change.rev);
     }
     // when change item processing is complete app can store seq
-    seq = changesItem.seq
+    seq = changesItem.seq;
     // write seq to persistent storage for use as since if required to resume later
-    // e.g. yourAppPersistenceWriteFunc()
+    // e.g. yourAppPersistenceWriteFunc();
   }
 }
 */

test/examples/src/features/ts/startAndProcess.ts

@@ -16,13 +16,13 @@
 import { ChangesFollower, CloudantV1, Stream } from '../../../../../index';
 import { ChangesResultItem, PostChangesParams } from '../../../../../cloudant/v1';
 import { Writable } from 'node:stream';
-import { pipeline } from 'node:stream/promises'
+import { pipeline } from 'node:stream/promises';
 
 const client = CloudantV1.newInstance({});
 // Start from a previously persisted seq
 // Normally this would be read by the app from persistent storage
 // e.g. previouslyPersistedSeq = yourAppPersistenceReadFunc()
-const previouslyPersistedSeq = '3-g1AG3...'
+const previouslyPersistedSeq = '3-g1AG3...';
 const changesParams: PostChangesParams = {
   db: 'example',
   since: previouslyPersistedSeq
@@ -36,10 +36,10 @@ const destinationStream = new Writable({
     // do something with change item
     console.log(changesItem.id);
     for (const change of changesItem.changes) {
-      console.log(change.rev)
+      console.log(change.rev);
     }
     // when change item processing is complete app can store seq
-    const seq = changesItem.seq
+    const seq = changesItem.seq;
     // write seq to persistent storage for use as since if required to resume later
     // e.g. yourAppPersistenceWriteFunc()
     callback();

test/examples/src/features/ts/startOneOffAndProcess.ts

@@ -16,13 +16,13 @@
 import { ChangesFollower, CloudantV1, Stream } from '../../../../../index';
 import { ChangesResultItem, PostChangesParams } from '../../../../../cloudant/v1';
 import { Writable } from 'node:stream';
-import { pipeline } from 'node:stream/promises'
+import { pipeline } from 'node:stream/promises';
 
 const client = CloudantV1.newInstance({});
 // Start from a previously persisted seq
 // Normally this would be read by the app from persistent storage
 // e.g. previouslyPersistedSeq = yourAppPersistenceReadFunc()
-const previouslyPersistedSeq = '3-g1AG3...'
+const previouslyPersistedSeq = '3-g1AG3...';
 const changesParams: PostChangesParams = {
   db: 'example',
   since: previouslyPersistedSeq
@@ -36,10 +36,10 @@ const destinationStream = new Writable({
     // do something with change item
     console.log(changesItem.id);
     for (const change of changesItem.changes) {
-      console.log(change.rev)
+      console.log(change.rev);
     }
     // when change item processing is complete app can store seq
-    const seq = changesItem.seq
+    const seq = changesItem.seq;
     // write seq to persistent storage for use as since if required to resume later
     // e.g. yourAppPersistenceWriteFunc()
     callback();
@@ -63,12 +63,12 @@ async function getChangesFromFollower(changesItemsStream: Stream<CloudantV1.Chan
     // write seq to persistent storage for use as since
     console.log(changesItem.id);
     for (const change of changesItem.changes) {
-      console.log(change.rev)
+      console.log(change.rev);
     }
     // when change item processing is complete app can store seq
-    seq = changesItem.seq
+    seq = changesItem.seq;
     // write seq to persistent storage for use as since if required to resume later
-    // e.g. yourAppPersistenceWriteFunc()
+    // e.g. yourAppPersistenceWriteFunc();
   }
 }
 */

test/examples/src/features/ts/stop.ts

@@ -16,7 +16,7 @@
 import { ChangesFollower, CloudantV1, Stream } from '../../../../../index';
 import { ChangesResultItem, PostChangesParams } from '../../../../../cloudant/v1';
 import { Writable } from 'node:stream';
-import { pipeline } from 'node:stream/promises'
+import { pipeline } from 'node:stream/promises';
 
 
 const client = CloudantV1.newInstance({});