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