diff --git a/src/extra/debounce.ts b/src/extra/debounce.ts index 1938277..1514c90 100644 --- a/src/extra/debounce.ts +++ b/src/extra/debounce.ts @@ -93,8 +93,8 @@ class DebounceOperator implements Operator { * @param {number} period The amount of silence required in milliseconds. * @return {Stream} */ -export default function debounce(period: number): (ins: Stream) => Stream { - return function debounceOperator(ins: Stream) { +export default function debounce(period: number): (ins: Stream) => Stream { + return function debounceOperator(ins: Stream) { return new Stream(new DebounceOperator(period, ins)); }; } diff --git a/tests/extra/debounce.ts b/tests/extra/debounce.ts index 093dcca..19d96bb 100644 --- a/tests/extra/debounce.ts +++ b/tests/extra/debounce.ts @@ -13,7 +13,7 @@ describe('debounce (extra)', () => { out.next(5); }, stop() {} - } + }; const stream = xs.create(producer).compose(debounce(100)); const expected = [5]; let listener = {