12 lines
268 B
JavaScript
12 lines
268 B
JavaScript
import { Observable, helpers } from 'rx';
|
|
|
|
export default function castToObservable(maybe) {
|
|
if (Observable.isObservable(maybe)) {
|
|
return maybe;
|
|
}
|
|
if (helpers.isPromise(maybe)) {
|
|
return Observable.fromPromise(maybe);
|
|
}
|
|
return Observable.of(maybe);
|
|
}
|