From 24d59e823737a14cad8d1e3c534b0e8b78334cda Mon Sep 17 00:00:00 2001 From: David Hearnden Date: Mon, 23 Mar 2020 19:02:22 +1100 Subject: [PATCH] makes Flowable.error() and Flowable.never() return a Flowable --- packages/rsocket-flowable/src/Flowable.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/rsocket-flowable/src/Flowable.js b/packages/rsocket-flowable/src/Flowable.js index 2ce22cd8..7efe41c2 100644 --- a/packages/rsocket-flowable/src/Flowable.js +++ b/packages/rsocket-flowable/src/Flowable.js @@ -61,7 +61,7 @@ export default class Flowable implements IPublisher { }); } - static error(error: Error): Flowable { + static error(error: Error): Flowable { return new Flowable(subscriber => { subscriber.onSubscribe({ cancel: () => {}, @@ -72,7 +72,7 @@ export default class Flowable implements IPublisher { }); } - static never(): Flowable { + static never(): Flowable { return new Flowable(subscriber => { subscriber.onSubscribe({ cancel: emptyFunction,