1 | import { isFunction } from './isiterable';
|
2 | const noop = (_) => {
|
3 |
|
4 | };
|
5 |
|
6 | export function toObserver(next, error, complete) {
|
7 | const observer = next;
|
8 | if (observer && typeof observer === 'object') {
|
9 | return {
|
10 | next: isFunction(observer.next) ? x => observer.next(x) : noop,
|
11 | error: isFunction(observer.error) ? e => observer.error(e) : noop,
|
12 | complete: isFunction(observer.complete) ? () => observer.complete() : noop
|
13 | };
|
14 | }
|
15 | return {
|
16 | next: isFunction(next) ? next : noop,
|
17 | error: isFunction(error) ? error : noop,
|
18 | complete: isFunction(complete) ? complete : noop
|
19 | };
|
20 | }
|
21 |
|
22 |
|