import { IScheduler } from '../Scheduler'; import { Observable } from '../Observable'; import { Subscriber } from '../Subscriber'; import { TeardownLogic } from '../Subscription'; /** * We need this JSDoc comment for affecting ESDoc. * @extends {Ignored} * @hide true */ export declare class PairsObservable extends Observable> { private obj; private scheduler; private keys; /** * Convert an object into an observable sequence of [key, value] pairs * using an optional IScheduler to enumerate the object. * * @example Converts a javascript object to an Observable * var obj = { * foo: 42, * bar: 56, * baz: 78 * }; * * var source = Rx.Observable.pairs(obj); * * var subscription = source.subscribe( * function (x) { * console.log('Next: %s', x); * }, * function (err) { * console.log('Error: %s', err); * }, * function () { * console.log('Completed'); * }); * * @param {Object} obj The object to inspect and turn into an * Observable sequence. * @param {Scheduler} [scheduler] An optional IScheduler to run the * enumeration of the input sequence on. * @returns {(Observable>)} An observable sequence of * [key, value] pairs from the object. */ static create(obj: Object, scheduler?: IScheduler): Observable>; constructor(obj: Object, scheduler?: IScheduler); /** @deprecated internal use only */ _subscribe(subscriber: Subscriber>): TeardownLogic; }