diff --git a/packages/rstream/src/from/interval.ts b/packages/rstream/src/from/interval.ts index f1dc1106f3..d80e38e79d 100644 --- 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((stream) => { let i = 0; + stream.next(i++); let id = setInterval(() => { stream.next(i++); if (--count <= 0) {