1 | import { BehaviorSubject, Observable, Observer, Subject, Subscription } from 'rxjs';
|
2 | import { IScheduler } from 'rxjs/Scheduler';
|
3 | export declare class ReactiveProperty<T> {
|
4 | private _value;
|
5 | private subject;
|
6 | constructor(value?: T);
|
7 | value: T;
|
8 | subscribe(observer: (value: T) => void | Observer<T>): Subscription;
|
9 | filter(selector: (value: T) => boolean): Observable<T>;
|
10 | map<U>(selector: (value: T) => U): Observable<U>;
|
11 | throttleTime(dueTime: number, scheduler?: IScheduler): Observable<T>;
|
12 | throttle<TTimeout>(selector: (value: T) => Observable<TTimeout>): Observable<T>;
|
13 | bufferTime(timeSpan: number, scheduler?: IScheduler): Observable<T[]>;
|
14 | bufferCount(count: number, skip?: number): Observable<T[]>;
|
15 | bufferTimeCount(timeSpan: number, count: number, skip?: number, scheduler?: IScheduler): Observable<T[]>;
|
16 | zip<U>(other: Observable<U>): Observable<[T, U]>;
|
17 | asObservable(): Observable<T>;
|
18 | asObserver(): Observer<T>;
|
19 | asSubject(): Subject<T>;
|
20 | asBehaviourSubject(): BehaviorSubject<T>;
|
21 | }
|