import { Observable } from 'rxjs/Observable'; import { Observer } from 'rxjs/Observer'; import { ReplaySubject } from 'rxjs/ReplaySubject'; import { IScheduler } from 'rxjs/Scheduler'; import { Subject } from 'rxjs/Subject'; import { Subscription } from 'rxjs/Subscription'; import { Consumer } from './../consumers/consumer'; import { Generator } from './../generators/generator'; import { AnyJson } from './../json/json.utils'; /** * Binds to the next function of a subject * * @param aSubject the subject that handles the events * * @return the binding function */ declare function _createConsumer(aSubject: Subject | Observer): Consumer; /** * Constructs a setter description * * @param aSubject the subject that handles the setter events * @return the description of the setter */ declare function _createSetter(aSubject: Subject): PropertyDescriptor; /** * Constructs a getter description * * @param aObservable the observable that handles the getter events * @param aInitial a potential initial value * @return the description of the getter */ declare function _createGetter(aObservable: Observable, aInitial?: T): PropertyDescriptor; declare const idleFrameScheduler: IScheduler; declare function _thisThenThat(aFirst: Observable, aNext: Observable): Observable; declare function _thisThenThats(...aObservables: Observable[]): Observable; /** * Constructs a singe replay subject * * @return the subject */ declare function _createSingleSubject(): ReplaySubject; declare function _generateItem(aGenerator: Generator): Observable; export declare const EMPTY_STRING_OBSERVABLE: Observable; export declare const EMPTY_JSON_OBSERVABLE: Observable; declare function _safeUnsubscribe(aSubscription: Subscription | null | undefined): void; declare function _safeUnsubscribeAll(aSubscriptions: Subscription[] | null | undefined): void; export { _thisThenThat as thisThenThat, _thisThenThats as thisThenThats, _createSingleSubject as createSingleSubject, _createSetter as createSetterOnSubject, _createConsumer as createConsumerOnSubject, _createGetter as createGetterOnObservable, _generateItem as generateItem, _safeUnsubscribe as safeUnsubscribe, _safeUnsubscribeAll as safeUnsubscribeAll, idleFrameScheduler };