included diagram

test/grpc1.ts

@@ -316,7 +316,7 @@ function stream(): Subject<any> {
   const intervalId = setInterval(() => {
     result.next(messages[count]);
     count++;
-    if (count >= 2000) {
+    if (count >= 2500) {
       clearInterval(intervalId);
       result.complete();
     }