| 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 |
|