diff --git a/packages/rsocket-flowable/src/Single.js b/packages/rsocket-flowable/src/Single.js index df90aaef..4d13661c 100644 --- a/packages/rsocket-flowable/src/Single.js +++ b/packages/rsocket-flowable/src/Single.js @@ -89,6 +89,12 @@ export default class Single { }); } + static never(): Single { + return new Single(subscriber => { + subscriber.onSubscribe(); + }); + } + constructor(source: Source) { this._source = source; }