Skip to content

Commit bb11e45

Browse files
authored
makes Flowable.error() and Flowable.never() return a Flowable<emp… (#79)
1 parent 7ca872a commit bb11e45

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

packages/rsocket-flowable/src/Flowable.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ export default class Flowable<T> implements IPublisher<T> {
6161
});
6262
}
6363

64-
static error<U>(error: Error): Flowable<U> {
64+
static error<U = empty>(error: Error): Flowable<U> {
6565
return new Flowable(subscriber => {
6666
subscriber.onSubscribe({
6767
cancel: () => {},
@@ -72,7 +72,7 @@ export default class Flowable<T> implements IPublisher<T> {
7272
});
7373
}
7474

75-
static never<U>(): Flowable<U> {
75+
static never<U = empty>(): Flowable<U> {
7676
return new Flowable(subscriber => {
7777
subscriber.onSubscribe({
7878
cancel: emptyFunction,

0 commit comments

Comments
 (0)