UNPKG

1.07 kBTypeScriptView Raw
1import { BehaviorSubject, Observable, Observer, Subject, Subscription } from 'rxjs';
2import { IScheduler } from 'rxjs/Scheduler';
3export 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}