File manager - Edit - /usr/local/lib/node_modules/ghost-cli/node_modules/inquirer/node_modules/rxjs/src/internal/util/subscribeToObservable.ts
Back
import { Subscriber } from '../Subscriber'; import { observable as Symbol_observable } from '../symbol/observable'; /** * Subscribes to an object that implements Symbol.observable with the given * Subscriber. * @param obj An object that implements Symbol.observable */ export const subscribeToObservable = <T>(obj: any) => (subscriber: Subscriber<T>) => { const obs = obj[Symbol_observable](); if (typeof obs.subscribe !== 'function') { // Should be caught by observable subscribe function error handling. throw new TypeError('Provided object does not correctly implement Symbol.observable'); } else { return obs.subscribe(subscriber); } };
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings