fix(rstream): emit first value immediately in fromInterval()

- previously first value was only emitted after `delay` ms
thi-ng · Jul 16, 2018 · 9be2018 · 9be2018
1 parent 0508e40
commit 9be2018
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/packages/rstream/src/from/interval.ts b/packages/rstream/src/from/interval.ts
@@ -12,6 +12,7 @@ import { Stream } from "../stream";
 export function fromInterval(delay: number, count = Number.POSITIVE_INFINITY) {
     return new Stream<number>((stream) => {
         let i = 0;
+        stream.next(i++);
         let id = setInterval(() => {
             stream.next(i++);
             if (--count <= 0) {