add comments and reformat

googleapis · Jun 22, 2019 · 5309534 · 5309534
1 parent f8d4a15
commit 5309534
Showing 1 changed file with 14 additions and 9 deletions.
diff --git a/dev/src/watch.ts b/dev/src/watch.ts
@@ -523,22 +523,27 @@ abstract class Watch {
             this.currentStream = backendStream;
             this.currentStream!.on('data', (proto: api.IListenResponse) => {
               this.onData(proto);
-            }).on('error', err => {
-              this.maybeReopenStream(err);
-            });
-            this.currentStream!.on('end', () => {
-              const err = new GrpcError('Stream ended unexpectedly');
-              err.code = GRPC_STATUS_CODE.UNKNOWN;
-              this.maybeReopenStream(err);
-            });
+            })
+              .on('error', err => {
+                this.maybeReopenStream(err);
+              })
+              .on('end', () => {
+                const err = new GrpcError('Stream ended unexpectedly');
+                err.code = GRPC_STATUS_CODE.UNKNOWN;
+                this.maybeReopenStream(err);
+              });
             this.currentStream!.resume();
           });
       })
       .catch(err => {
         this.closeStream(err);
       });
   }
-
+  /**
+   * Handles 'data' events and closes the stream if the response type is
+   * invalid.
+   * @private
+   */
   private onData(proto: api.IListenResponse): void {
     if (proto.targetChange) {
       logger('Watch.onSnapshot', this.requestTag, 'Processing target change');