mirror of
https://github.com/zhigang1992/DefinitelyTyped.git
synced 2026-05-30 10:35:22 +08:00
Diullei Gomes
16
rx.js/rx.js.aggregates.d.ts
vendored
Normal file
16
rx.js/rx.js.aggregates.d.ts
vendored
Normal file
@@ -0,0 +1,16 @@
|
||||
// Type definitions for RxJS "Aggregates"
|
||||
// Project: http://rx.codeplex.com/
|
||||
// Definitions by: Carl de Billy <http://carl.debilly.net/>
|
||||
// Definitions: https://github.com/borisyankov/DefinitelyTyped
|
||||
|
||||
///<reference path="rx.js.d.ts" />
|
||||
|
||||
declare module Rx {
|
||||
export module Observable {
|
||||
function all(predicate?: (any) => bool): IObservable;
|
||||
function min(predicate?: (any) => bool): IObservable;
|
||||
function max(predicate?: (any) => bool): IObservable;
|
||||
function count(predicate?: (any) => bool): IObservable;
|
||||
function sum(keySelector?: (any) => any): IObservable;
|
||||
}
|
||||
}
|
||||
914
rx.js/rx.js.d.ts
vendored
914
rx.js/rx.js.d.ts
vendored
@@ -1,453 +1,463 @@
|
||||
// Type definitions for RxJS
|
||||
// Project: http://rx.codeplex.com/
|
||||
// Definitions by: gsino <http://www.codeplex.com/site/users/view/gsino>
|
||||
// Definitions: https://github.com/borisyankov/DefinitelyTyped
|
||||
|
||||
|
||||
declare module Rx {
|
||||
export module Internals {
|
||||
function inherits(child: Function, parent: Function): Function;
|
||||
function addProperties(obj: Object, ...sourcces: Object[]): void;
|
||||
function addRef(xs: IObservable, r: { getDisposable(): _IDisposable; }): IObservable;
|
||||
}
|
||||
|
||||
//Collections
|
||||
interface IIndexedItem {
|
||||
id: number;
|
||||
value: IScheduledItem;
|
||||
|
||||
compareTo(other: IIndexedItem): number;
|
||||
}
|
||||
|
||||
// Priority Queue for Scheduling
|
||||
interface IPriorityQueue {
|
||||
items: IIndexedItem[];
|
||||
length: number;
|
||||
|
||||
isHigherPriority(left: number, right: number): bool;
|
||||
percolate(index: number): void;
|
||||
heapify(index: number): void;
|
||||
peek(): IIndexedItem;
|
||||
removeAt(index: number): void;
|
||||
dequeue(): IIndexedItem;
|
||||
enqueue(item: IIndexedItem): void;
|
||||
remove(item: IIndexedItem): bool;
|
||||
}
|
||||
|
||||
interface _IDisposable {
|
||||
dispose(): void;
|
||||
}
|
||||
|
||||
interface ICompositeDisposable {
|
||||
disposables: _IDisposable[];
|
||||
isDisposed: bool;
|
||||
length: number;
|
||||
|
||||
dispose(): void;
|
||||
add(item: _IDisposable): void;
|
||||
remove(item: _IDisposable): bool;
|
||||
clear(): void;
|
||||
contains(item: _IDisposable): bool;
|
||||
toArray(): _IDisposable[];
|
||||
}
|
||||
export module CompositeDisposable {
|
||||
function new (...disposables: _IDisposable[]): ICompositeDisposable;
|
||||
}
|
||||
|
||||
// Main disposable class
|
||||
interface IDisposable {
|
||||
isDisposed: bool;
|
||||
action: () =>void;
|
||||
|
||||
dispose(): void;
|
||||
}
|
||||
export module Disposable {
|
||||
function new (action: () =>void ): IDisposable;
|
||||
|
||||
function create(action: () =>void ): _IDisposable;
|
||||
var empty: _IDisposable;
|
||||
}
|
||||
|
||||
// Single assignment
|
||||
interface ISingleAssignmentDisposable {
|
||||
isDisposed: bool;
|
||||
current: _IDisposable;
|
||||
|
||||
dispose(): void;
|
||||
disposable(value?: _IDisposable): _IDisposable;
|
||||
getDisposable(): _IDisposable;
|
||||
setDisposable(value: _IDisposable): void;
|
||||
}
|
||||
export module SingleAssignmentDisposable {
|
||||
function new (): ISingleAssignmentDisposable;
|
||||
}
|
||||
|
||||
// Multiple assignment disposable
|
||||
interface ISerialDisposable {
|
||||
isDisposed: bool;
|
||||
current: _IDisposable;
|
||||
|
||||
dispose(): void;
|
||||
getDisposable(): _IDisposable;
|
||||
setDisposable(value: _IDisposable): void;
|
||||
disposable(value?: _IDisposable): _IDisposable;
|
||||
}
|
||||
export module SerialDisposable {
|
||||
function new (): ISerialDisposable;
|
||||
}
|
||||
|
||||
interface IRefCountDisposable {
|
||||
underlyingDisposable: _IDisposable;
|
||||
isDisposed: bool;
|
||||
isPrimaryDisposed: bool;
|
||||
count: number;
|
||||
|
||||
dispose(): void;
|
||||
getDisposable(): _IDisposable;
|
||||
}
|
||||
export module RefCountDisposable {
|
||||
function new (disposable: _IDisposable): IRefCountDisposable;
|
||||
}
|
||||
|
||||
interface IScheduledItem {
|
||||
scheduler: IScheduler;
|
||||
state: any;
|
||||
action: (scheduler: IScheduler, state) => _IDisposable;
|
||||
dueTime: number;
|
||||
comparer: (x: number, y: number) =>number;
|
||||
disposable: ISingleAssignmentDisposable;
|
||||
|
||||
invoke(): void;
|
||||
compareTo(other: IScheduledItem): number;
|
||||
isCancelled(): bool;
|
||||
invokeCore(): _IDisposable;
|
||||
}
|
||||
|
||||
interface IScheduler {
|
||||
_schedule: (state: any, action: (scheduler: IScheduler, state: any) =>_IDisposable) => _IDisposable;
|
||||
_scheduleRelative: (state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable) =>_IDisposable;
|
||||
_scheduleAbsolute: (state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable) =>_IDisposable;
|
||||
|
||||
now(): number;
|
||||
scheduleWithState(state: any, action: (scheduler: IScheduler, state: any) =>_IDisposable): _IDisposable;
|
||||
scheduleWithAbsoluteAndState(state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable): _IDisposable;
|
||||
scheduleWithRelativeAndState(state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable): _IDisposable;
|
||||
|
||||
catchException(handler: (exception: any) =>bool): ICatchScheduler;
|
||||
schedulePeriodic(period: number, action: () =>void ): _IDisposable;
|
||||
schedulePeriodicWithState(state: any, period: number, action: (state: any) =>any): _IDisposable;//returns {Disposable|SingleAssignmentDisposable}
|
||||
schedule(action: () =>void ): _IDisposable;
|
||||
scheduleWithRelative(dueTime: number, action: () =>void ): _IDisposable;
|
||||
scheduleWithAbsolute(dueTime: number, action: () =>void ): _IDisposable;
|
||||
scheduleRecursive(action: (action: () =>void ) =>void ): _IDisposable;
|
||||
scheduleRecursiveWithState(state: any, action: (state: any, action: (state: any) =>void ) =>void ): _IDisposable;
|
||||
scheduleRecursiveWithRelative(dueTime: number, action: (action: (dueTime: number) =>void ) =>void ): _IDisposable;
|
||||
scheduleRecursiveWithRelativeAndState(state: any, dueTime: number, action: (state: any, action: (state: any, dueTime: number) =>void ) =>void ): _IDisposable;
|
||||
scheduleRecursiveWithAbsolute(dueTime: number, action: (action: (dueTime: number) =>void ) =>void ): _IDisposable;
|
||||
scheduleRecursiveWithAbsoluteAndState(state: any, dueTime: number, action: (state: any, action: (state: any, dueTime: number) =>void ) =>void ): _IDisposable;
|
||||
}
|
||||
export module Scheduler {
|
||||
function new (now: () =>number,
|
||||
schedule: (state: any, action: (scheduler: IScheduler, state: any) =>_IDisposable) => _IDisposable,
|
||||
scheduleRelative: (state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable) =>_IDisposable,
|
||||
scheduleAbsolute: (state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable) =>_IDisposable
|
||||
): IScheduler;
|
||||
|
||||
function now(): number;
|
||||
function normalize(timeSpan: number): number;
|
||||
|
||||
var immediate: IScheduler;
|
||||
var currentThread: ICurrentScheduler;//IScheduler;
|
||||
var timeout: IScheduler;
|
||||
}
|
||||
|
||||
// Current Thread IScheduler
|
||||
interface ICurrentScheduler extends IScheduler {
|
||||
scheduleRequired(): bool;
|
||||
ensureTrampoline(action: () =>_IDisposable): _IDisposable;
|
||||
}
|
||||
|
||||
// Virtual IScheduler
|
||||
interface IVirtualTimeScheduler extends IScheduler {
|
||||
toRelative(duetime): number;
|
||||
toDateTimeOffset(duetime: number): number;
|
||||
|
||||
clock: number;
|
||||
comparer: (x: number, y: number) =>number;
|
||||
isEnabled: bool;
|
||||
queue: IPriorityQueue;
|
||||
scheduleRelativeWithState(state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable): _IDisposable;
|
||||
scheduleRelative(dueTime: number, action: () =>void ): _IDisposable;
|
||||
start(): _IDisposable;
|
||||
stop(): void;
|
||||
advanceTo(time: number);
|
||||
advanceBy(time: number);
|
||||
sleep(time: number);
|
||||
getNext(): IScheduledItem;
|
||||
scheduleAbsolute(dueTime: number, action: () =>void );
|
||||
scheduleAbsoluteWithState(state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable): _IDisposable;
|
||||
}
|
||||
//export module VirtualTimeScheduler {
|
||||
// //absract
|
||||
// function new (initialClock: number, comparer: (x: number, y: number) =>number): IVirtualTimeScheduler;
|
||||
//}
|
||||
|
||||
|
||||
// CatchScheduler
|
||||
interface ICatchScheduler extends IScheduler { }
|
||||
|
||||
// Notifications
|
||||
interface INotification {
|
||||
accept(observer: IObserver): void;
|
||||
accept(onNext: (value: any) =>void , onError?: (exception: any) =>void , onCompleted?: () =>void ): void;
|
||||
toObservable(scheduler?: IScheduler): IObservable;
|
||||
hasValue: bool;
|
||||
equals(other: INotification): bool;
|
||||
}
|
||||
export module Notification {
|
||||
//absctract
|
||||
//function new (): INotification;
|
||||
|
||||
function createOnNext(value: any): INotification;//ON
|
||||
function createOnError(exception): INotification;//OE
|
||||
function createOnCompleted(): INotification;//OC
|
||||
}
|
||||
|
||||
export module Internals {
|
||||
// Enumerator
|
||||
interface IEnumerator {
|
||||
moveNext(): bool;
|
||||
getCurrent(): any;
|
||||
dispose(): void;
|
||||
}
|
||||
export module Enumerator {
|
||||
function new (moveNext: () =>bool, getCurrent: () => any, dispose: () =>void ): IEnumerator;
|
||||
|
||||
function create(moveNext: () =>bool, getCurrent: () =>any, dispose?: () =>void ): IEnumerator;
|
||||
}
|
||||
|
||||
// Enumerable
|
||||
interface IEnumerable {
|
||||
getEnumerator(): IEnumerator;
|
||||
|
||||
concat(): IObservable;
|
||||
catchException(): IObservable;
|
||||
}
|
||||
export module Enumerable {
|
||||
function new (getEnumerator: () =>IEnumerator): IEnumerable;
|
||||
|
||||
function repeat(value: any, repeatCount?: number): IEnumerable;
|
||||
function forEach(source: any[], selector?: (element: any, index: number) =>any): IEnumerable;
|
||||
function forEach(source: { length: number;[index: number]: any; }, selector?: (element: any, index: number) =>any): IEnumerable;
|
||||
}
|
||||
}
|
||||
|
||||
// Observer
|
||||
interface IObserver {
|
||||
onNext(value: any): void;
|
||||
onError(exception: any): void;
|
||||
onCompleted(): void;
|
||||
|
||||
toNotifier(): (notification: INotification) =>void;
|
||||
asObserver(): IObserver;
|
||||
checked(): ICheckedObserver;
|
||||
}
|
||||
export module Observer {
|
||||
//abstract
|
||||
//function new (): IObserver;
|
||||
|
||||
function create(onNext: (value: any) =>void , onError?: (exception: any) =>void , onCompleted?: () =>void ): IObserver;
|
||||
function fromNotifier(handler: (notification: INotification) =>void ): IObserver;
|
||||
}
|
||||
|
||||
export module Internals {
|
||||
// Abstract Observer
|
||||
interface IAbstractObserver extends IObserver {
|
||||
isStopped: bool;
|
||||
|
||||
dispose(): void;
|
||||
next(value: any): void;
|
||||
error(exception: any): void;
|
||||
completed(): void;
|
||||
fail(): bool;
|
||||
}
|
||||
//export module AbstractObserver {
|
||||
// //abstract
|
||||
// function new (): IAbstractObserver;
|
||||
//}
|
||||
}
|
||||
|
||||
interface IAnonymousObserver extends Internals.IAbstractObserver {
|
||||
_onNext: (value: any) =>void;
|
||||
_onError: (exception: any) =>void;
|
||||
_onCompleted: () =>void;
|
||||
}
|
||||
export module AnonymousObserver {
|
||||
function new (onNext: (value: any) =>void , onError: (exception: any) =>void , onCompleted: () =>void ): IAnonymousObserver;
|
||||
}
|
||||
|
||||
interface ICheckedObserver extends IObserver {
|
||||
_observer: IObserver;
|
||||
_state: number; // 0 - idle, 1 - busy, 2 - done
|
||||
checkAccess(): void;
|
||||
}
|
||||
|
||||
export module Internals {
|
||||
interface IScheduledObserver extends IAbstractObserver {
|
||||
scheduler: IScheduler;
|
||||
observer: IObserver;
|
||||
isAcquired: bool;
|
||||
hasFaulted: bool;
|
||||
queue: { (value: any): void; (exception: any): void; (): void; }[];
|
||||
disposable: ISerialDisposable;
|
||||
|
||||
ensureActive(): void;
|
||||
}
|
||||
export module ScheduledObserver {
|
||||
function new (scheduler: IScheduler, observer: IObserver): IScheduledObserver;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
interface IObservable {
|
||||
_subscribe: (observer: IObserver) =>_IDisposable;
|
||||
|
||||
subscribe(observer: IObserver): _IDisposable;
|
||||
|
||||
finalValue(): IObservable;
|
||||
subscribe(onNext?: (value: any) =>void , onError?: (exception: any) =>void , onCompleted?: () =>void ): _IDisposable;
|
||||
toArray(): IObservable;
|
||||
|
||||
observeOn(scheduler: IScheduler): IObservable;
|
||||
subscribeOn(scheduler: IScheduler): IObservable;
|
||||
amb(rightSource: IObservable): IObservable;
|
||||
catchException(handler: (exception: any) =>IObservable): IObservable;
|
||||
catchException(second: IObservable): IObservable;
|
||||
combineLatest(second: IObservable, resultSelector: (v1: any, v2: any) =>any): IObservable;
|
||||
combineLatest(second: IObservable, third: IObservable, resultSelector: (v1: any, v2: any, v3: any) =>any): IObservable;
|
||||
combineLatest(second: IObservable, third: IObservable, fourth: IObservable, resultSelector: (v1: any, v2: any, v3: any, v4: any) =>any): IObservable;
|
||||
combineLatest(second: IObservable, third: IObservable, fourth: IObservable, fifth, IObservable, resultSelector: (v1: any, v2: any, v3: any, v4: any, v5: any) =>any): IObservable;
|
||||
combineLatest(...soucesAndResultSelector: any[]): IObservable;
|
||||
concat(...sources: IObservable[]): IObservable;
|
||||
concat(sources: IObservable[]): IObservable;
|
||||
concatIObservable(): IObservable;
|
||||
merge(maxConcurrent: number): IObservable;
|
||||
merge(other: IObservable): IObservable;
|
||||
mergeIObservable(): IObservable;
|
||||
onErrorResumeNext(second: IObservable): IObservable;
|
||||
skipUntil(other: IObservable): IObservable;
|
||||
switchLatest(): IObservable;
|
||||
takeUntil(other: IObservable): IObservable;
|
||||
zip(second: IObservable, resultSelector: (v1: any, v2: any) =>any): IObservable;
|
||||
zip(second: IObservable, third: IObservable, resultSelector: (v1: any, v2: any, v3: any) =>any): IObservable;
|
||||
zip(second: IObservable, third: IObservable, fourth: IObservable, resultSelector: (v1: any, v2: any, v3: any, v4: any) =>any): IObservable;
|
||||
zip(second: IObservable, third: IObservable, fourth: IObservable, fifth, IObservable, resultSelector: (v1: any, v2: any, v3: any, v4: any, v5: any) =>any): IObservable;
|
||||
zip(...soucesAndResultSelector: any[]): IObservable;
|
||||
zip(second: any[], resultSelector: (left: any, right: any) =>any): IObservable;
|
||||
asIObservable(): IObservable;
|
||||
bufferWithCount(count: number, skip?: number): IObservable;
|
||||
dematerialize(): IObservable;
|
||||
distinctUntilChanged(keySelector?: (value: any) =>any, comparer?: (x: any, y: any) =>bool): IObservable;
|
||||
doAction(observer: IObserver): IObservable;
|
||||
doAction(onNext: (value: any) => void , onError?: (exception: any) =>void , onCompleted?: () =>void ): IObservable;
|
||||
finallyAction(action: () =>void ): IObservable;
|
||||
ignoreElements(): IObservable;
|
||||
materialize(): IObservable;
|
||||
repeat(repeatCount?: number): IObservable;
|
||||
retry(retryCount?: number): IObservable;
|
||||
scan(seed: number, accumulator: (acc: any, value: any) =>any): IObservable;
|
||||
scan(accumulator: (acc: any, value: any) =>any): IObservable;
|
||||
skipLast(count: number): IObservable;
|
||||
startWith(...values: any[]): IObservable;
|
||||
startWith(scheduler: IScheduler, ...values: any[]): IObservable;
|
||||
takeLast(count: number, scheduler?: IScheduler): IObservable;
|
||||
takeLastBuffer(count: number): IObservable;
|
||||
windowWithCount(count: number, skip?: number): IObservable;
|
||||
defaultIfEmpty(defaultValue?: any): IObservable;
|
||||
distinct(keySelector?: (value: any) =>any, keySerializer?: (key: any) =>string): IObservable;
|
||||
groupBy(keySelector: (value: any) =>any, elementSelector?: (value: any) =>any, keySerializer?: (key: any) =>string): IGroupedObservable;
|
||||
groupByUntil(keySelector: (value: any) =>any, elementSelector: (value: any) =>any, durationSelector: (gloup: IGroupedObservable) =>IObservable, keySerializer?: (key: any) =>string): IGroupedObservable;
|
||||
select(selector: (value: any, index: number) =>any): IObservable;
|
||||
selectMany(selector: (value: any) =>IObservable, resultSelector?: (x: any, y: any) =>any): IObservable;
|
||||
selectMany(other: IObservable): IObservable;
|
||||
skip(count: number): IObservable;
|
||||
skipWhile(predicate: (value: any, index?: number) =>bool): IObservable;
|
||||
take(count: number, scheduler?: IScheduler): IObservable;
|
||||
takeWhile(predicate: (value: any, index?: number) =>bool): IObservable;
|
||||
where(predicate: (value: any, index?: number) =>bool): IObservable;
|
||||
}
|
||||
export module Observable {
|
||||
function new (subscribe: (observer: IObserver) =>_IDisposable): IObservable;
|
||||
|
||||
function start(func: () =>any, scheduler?: IScheduler, context?: any): IObservable;
|
||||
function toAsync(func: Function, scheduler?: IScheduler, context?: any): (...arguments: any[]) => IObservable;
|
||||
function create(subscribe: (Observer) =>() =>void ): IObservable;
|
||||
function createWithDisposable(subscribe: (Observer) =>_IDisposable): IObservable;
|
||||
function defer(observableFactory: () =>IObservable): IObservable;
|
||||
function empty(scheduler?: IScheduler): IObservable;
|
||||
function fromArray(array: any[], scheduler?: IScheduler): IObservable;
|
||||
function fromArray(array: { length: number;[index: number]: any; }, scheduler?: IScheduler): IObservable;
|
||||
function generate(initialState: any, condition: (state: any) =>bool, iterate: (state: any) =>any, resultSelector: (state: any) =>any, scheduler?: IScheduler): IObservable;
|
||||
function never(): IObservable;
|
||||
function range(start: number, count: number, scheduler?: IScheduler): IObservable;
|
||||
function repeat(value: any, repeatCount?: number, scheduler?: IScheduler): IObservable;
|
||||
function returnValue(value: any, scheduler?: IScheduler): IObservable;
|
||||
function throwException(exception: any, scheduler?: IScheduler): IObservable;
|
||||
function using(resourceFactory: () =>any, observableFactory: (resource: any) =>IObservable): IObservable;
|
||||
function amb(...sources: IObservable[]): IObservable;
|
||||
function catchException(sources: IObservable[]): IObservable;
|
||||
function catchException(...sources: IObservable[]): IObservable;
|
||||
function concat(...sources: IObservable[]): IObservable;
|
||||
function concat(sources: IObservable[]): IObservable;
|
||||
function merge(...sources: IObservable[]): IObservable;
|
||||
function merge(sources: IObservable[]): IObservable;
|
||||
function merge(scheduler: IScheduler, ...sources: IObservable[]): IObservable;
|
||||
function merge(scheduler: IScheduler, sources: IObservable[]): IObservable;
|
||||
function onErrorResumeNext(...sources: IObservable[]): IObservable;
|
||||
function onErrorResumeNext(sources: IObservable[]): IObservable;
|
||||
}
|
||||
|
||||
export module Internals {
|
||||
interface IAnonymousObservable extends IObservable { }
|
||||
export module AnonymousObservable {
|
||||
function new (subscribe: (observer: IObserver) =>_IDisposable): IAnonymousObservable;
|
||||
}
|
||||
}
|
||||
|
||||
interface IGroupedObservable extends IObservable {
|
||||
key: any;
|
||||
underlyingObservable: IObservable;
|
||||
}
|
||||
|
||||
interface ISubject extends IObservable, IObserver {
|
||||
isDisposed: bool;
|
||||
isStopped: bool;
|
||||
observers: IObserver[];
|
||||
|
||||
dispose(): void;
|
||||
}
|
||||
export module Subject {
|
||||
function new (): ISubject;
|
||||
|
||||
function create(observer: IObserver, observable: IObservable): ISubject;
|
||||
}
|
||||
|
||||
interface IAsyncSubject extends IObservable, IObserver {
|
||||
isDisposed: bool;
|
||||
value: any;
|
||||
hasValue: bool;
|
||||
observers: IObserver[];
|
||||
exception: any;
|
||||
|
||||
dispose(): void;
|
||||
}
|
||||
export module AsyncSubject {
|
||||
function new (): IAsyncSubject;
|
||||
}
|
||||
|
||||
interface IAnonymousSubject extends IObservable {
|
||||
onNext(value: any): void;
|
||||
onError(exception: any): void;
|
||||
onCompleted(): void;
|
||||
}
|
||||
// Type definitions for RxJS
|
||||
// Project: http://rx.codeplex.com/
|
||||
// Definitions by: gsino <http://www.codeplex.com/site/users/view/gsino>
|
||||
// Definitions: https://github.com/borisyankov/DefinitelyTyped
|
||||
|
||||
|
||||
declare module Rx {
|
||||
export module Internals {
|
||||
function inherits(child: Function, parent: Function): Function;
|
||||
function addProperties(obj: Object, ...sourcces: Object[]): void;
|
||||
function addRef(xs: IObservable, r: { getDisposable(): _IDisposable; }): IObservable;
|
||||
}
|
||||
|
||||
//Collections
|
||||
interface IIndexedItem {
|
||||
id: number;
|
||||
value: IScheduledItem;
|
||||
|
||||
compareTo(other: IIndexedItem): number;
|
||||
}
|
||||
|
||||
// Priority Queue for Scheduling
|
||||
interface IPriorityQueue {
|
||||
items: IIndexedItem[];
|
||||
length: number;
|
||||
|
||||
isHigherPriority(left: number, right: number): bool;
|
||||
percolate(index: number): void;
|
||||
heapify(index: number): void;
|
||||
peek(): IIndexedItem;
|
||||
removeAt(index: number): void;
|
||||
dequeue(): IIndexedItem;
|
||||
enqueue(item: IIndexedItem): void;
|
||||
remove(item: IIndexedItem): bool;
|
||||
}
|
||||
|
||||
interface _IDisposable {
|
||||
dispose(): void;
|
||||
}
|
||||
|
||||
interface ICompositeDisposable {
|
||||
disposables: _IDisposable[];
|
||||
isDisposed: bool;
|
||||
length: number;
|
||||
|
||||
dispose(): void;
|
||||
add(item: _IDisposable): void;
|
||||
remove(item: _IDisposable): bool;
|
||||
clear(): void;
|
||||
contains(item: _IDisposable): bool;
|
||||
toArray(): _IDisposable[];
|
||||
}
|
||||
export module CompositeDisposable {
|
||||
function new (...disposables: _IDisposable[]): ICompositeDisposable;
|
||||
}
|
||||
|
||||
// Main disposable class
|
||||
interface IDisposable {
|
||||
isDisposed: bool;
|
||||
action: () =>void;
|
||||
|
||||
dispose(): void;
|
||||
}
|
||||
export module Disposable {
|
||||
function new (action: () =>void ): IDisposable;
|
||||
|
||||
function create(action: () =>void ): _IDisposable;
|
||||
var empty: _IDisposable;
|
||||
}
|
||||
|
||||
// Single assignment
|
||||
interface ISingleAssignmentDisposable {
|
||||
isDisposed: bool;
|
||||
current: _IDisposable;
|
||||
|
||||
dispose(): void;
|
||||
disposable(value?: _IDisposable): _IDisposable;
|
||||
getDisposable(): _IDisposable;
|
||||
setDisposable(value: _IDisposable): void;
|
||||
}
|
||||
export module SingleAssignmentDisposable {
|
||||
function new (): ISingleAssignmentDisposable;
|
||||
}
|
||||
|
||||
// Multiple assignment disposable
|
||||
interface ISerialDisposable {
|
||||
isDisposed: bool;
|
||||
current: _IDisposable;
|
||||
|
||||
dispose(): void;
|
||||
getDisposable(): _IDisposable;
|
||||
setDisposable(value: _IDisposable): void;
|
||||
disposable(value?: _IDisposable): _IDisposable;
|
||||
}
|
||||
export module SerialDisposable {
|
||||
function new (): ISerialDisposable;
|
||||
}
|
||||
|
||||
interface IRefCountDisposable {
|
||||
underlyingDisposable: _IDisposable;
|
||||
isDisposed: bool;
|
||||
isPrimaryDisposed: bool;
|
||||
count: number;
|
||||
|
||||
dispose(): void;
|
||||
getDisposable(): _IDisposable;
|
||||
}
|
||||
export module RefCountDisposable {
|
||||
function new (disposable: _IDisposable): IRefCountDisposable;
|
||||
}
|
||||
|
||||
interface IScheduledItem {
|
||||
scheduler: IScheduler;
|
||||
state: any;
|
||||
action: (scheduler: IScheduler, state) => _IDisposable;
|
||||
dueTime: number;
|
||||
comparer: (x: number, y: number) =>number;
|
||||
disposable: ISingleAssignmentDisposable;
|
||||
|
||||
invoke(): void;
|
||||
compareTo(other: IScheduledItem): number;
|
||||
isCancelled(): bool;
|
||||
invokeCore(): _IDisposable;
|
||||
}
|
||||
|
||||
interface IScheduler {
|
||||
_schedule: (state: any, action: (scheduler: IScheduler, state: any) =>_IDisposable) => _IDisposable;
|
||||
_scheduleRelative: (state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable) =>_IDisposable;
|
||||
_scheduleAbsolute: (state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable) =>_IDisposable;
|
||||
|
||||
now(): number;
|
||||
scheduleWithState(state: any, action: (scheduler: IScheduler, state: any) =>_IDisposable): _IDisposable;
|
||||
scheduleWithAbsoluteAndState(state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable): _IDisposable;
|
||||
scheduleWithRelativeAndState(state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable): _IDisposable;
|
||||
|
||||
catchException(handler: (exception: any) =>bool): ICatchScheduler;
|
||||
schedulePeriodic(period: number, action: () =>void ): _IDisposable;
|
||||
schedulePeriodicWithState(state: any, period: number, action: (state: any) =>any): _IDisposable;//returns {Disposable|SingleAssignmentDisposable}
|
||||
schedule(action: () =>void ): _IDisposable;
|
||||
scheduleWithRelative(dueTime: number, action: () =>void ): _IDisposable;
|
||||
scheduleWithAbsolute(dueTime: number, action: () =>void ): _IDisposable;
|
||||
scheduleRecursive(action: (action: () =>void ) =>void ): _IDisposable;
|
||||
scheduleRecursiveWithState(state: any, action: (state: any, action: (state: any) =>void ) =>void ): _IDisposable;
|
||||
scheduleRecursiveWithRelative(dueTime: number, action: (action: (dueTime: number) =>void ) =>void ): _IDisposable;
|
||||
scheduleRecursiveWithRelativeAndState(state: any, dueTime: number, action: (state: any, action: (state: any, dueTime: number) =>void ) =>void ): _IDisposable;
|
||||
scheduleRecursiveWithAbsolute(dueTime: number, action: (action: (dueTime: number) =>void ) =>void ): _IDisposable;
|
||||
scheduleRecursiveWithAbsoluteAndState(state: any, dueTime: number, action: (state: any, action: (state: any, dueTime: number) =>void ) =>void ): _IDisposable;
|
||||
}
|
||||
export module Scheduler {
|
||||
function new (now: () =>number,
|
||||
schedule: (state: any, action: (scheduler: IScheduler, state: any) =>_IDisposable) => _IDisposable,
|
||||
scheduleRelative: (state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable) =>_IDisposable,
|
||||
scheduleAbsolute: (state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable) =>_IDisposable
|
||||
): IScheduler;
|
||||
|
||||
function now(): number;
|
||||
function normalize(timeSpan: number): number;
|
||||
|
||||
var immediate: IScheduler;
|
||||
var currentThread: ICurrentScheduler;//IScheduler;
|
||||
var timeout: IScheduler;
|
||||
}
|
||||
|
||||
// Current Thread IScheduler
|
||||
interface ICurrentScheduler extends IScheduler {
|
||||
scheduleRequired(): bool;
|
||||
ensureTrampoline(action: () =>_IDisposable): _IDisposable;
|
||||
}
|
||||
|
||||
// Virtual IScheduler
|
||||
interface IVirtualTimeScheduler extends IScheduler {
|
||||
toRelative(duetime): number;
|
||||
toDateTimeOffset(duetime: number): number;
|
||||
|
||||
clock: number;
|
||||
comparer: (x: number, y: number) =>number;
|
||||
isEnabled: bool;
|
||||
queue: IPriorityQueue;
|
||||
scheduleRelativeWithState(state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable): _IDisposable;
|
||||
scheduleRelative(dueTime: number, action: () =>void ): _IDisposable;
|
||||
start(): _IDisposable;
|
||||
stop(): void;
|
||||
advanceTo(time: number);
|
||||
advanceBy(time: number);
|
||||
sleep(time: number);
|
||||
getNext(): IScheduledItem;
|
||||
scheduleAbsolute(dueTime: number, action: () =>void );
|
||||
scheduleAbsoluteWithState(state: any, dueTime: number, action: (scheduler: IScheduler, state: any) =>_IDisposable): _IDisposable;
|
||||
}
|
||||
//export module VirtualTimeScheduler {
|
||||
// //absract
|
||||
// function new (initialClock: number, comparer: (x: number, y: number) =>number): IVirtualTimeScheduler;
|
||||
//}
|
||||
|
||||
|
||||
// CatchScheduler
|
||||
interface ICatchScheduler extends IScheduler { }
|
||||
|
||||
// Notifications
|
||||
interface INotification {
|
||||
accept(observer: IObserver): void;
|
||||
accept(onNext: (value: any) =>void , onError?: (exception: any) =>void , onCompleted?: () =>void ): void;
|
||||
toObservable(scheduler?: IScheduler): IObservable;
|
||||
hasValue: bool;
|
||||
equals(other: INotification): bool;
|
||||
}
|
||||
export module Notification {
|
||||
//absctract
|
||||
//function new (): INotification;
|
||||
|
||||
function createOnNext(value: any): INotification;//ON
|
||||
function createOnError(exception): INotification;//OE
|
||||
function createOnCompleted(): INotification;//OC
|
||||
}
|
||||
|
||||
export module Internals {
|
||||
// Enumerator
|
||||
interface IEnumerator {
|
||||
moveNext(): bool;
|
||||
getCurrent(): any;
|
||||
dispose(): void;
|
||||
}
|
||||
export module Enumerator {
|
||||
function new (moveNext: () =>bool, getCurrent: () => any, dispose: () =>void ): IEnumerator;
|
||||
|
||||
function create(moveNext: () =>bool, getCurrent: () =>any, dispose?: () =>void ): IEnumerator;
|
||||
}
|
||||
|
||||
// Enumerable
|
||||
interface IEnumerable {
|
||||
getEnumerator(): IEnumerator;
|
||||
|
||||
concat(): IObservable;
|
||||
catchException(): IObservable;
|
||||
}
|
||||
export module Enumerable {
|
||||
function new (getEnumerator: () =>IEnumerator): IEnumerable;
|
||||
|
||||
function repeat(value: any, repeatCount?: number): IEnumerable;
|
||||
function forEach(source: any[], selector?: (element: any, index: number) =>any): IEnumerable;
|
||||
function forEach(source: { length: number;[index: number]: any; }, selector?: (element: any, index: number) =>any): IEnumerable;
|
||||
}
|
||||
}
|
||||
|
||||
// Observer
|
||||
interface IObserver {
|
||||
onNext(value: any): void;
|
||||
onError(exception: any): void;
|
||||
onCompleted(): void;
|
||||
|
||||
toNotifier(): (notification: INotification) =>void;
|
||||
asObserver(): IObserver;
|
||||
checked(): ICheckedObserver;
|
||||
}
|
||||
export module Observer {
|
||||
//abstract
|
||||
//function new (): IObserver;
|
||||
|
||||
function create(onNext: (value: any) =>void , onError?: (exception: any) =>void , onCompleted?: () =>void ): IObserver;
|
||||
function fromNotifier(handler: (notification: INotification) =>void ): IObserver;
|
||||
}
|
||||
|
||||
export module Internals {
|
||||
// Abstract Observer
|
||||
interface IAbstractObserver extends IObserver {
|
||||
isStopped: bool;
|
||||
|
||||
dispose(): void;
|
||||
next(value: any): void;
|
||||
error(exception: any): void;
|
||||
completed(): void;
|
||||
fail(): bool;
|
||||
}
|
||||
//export module AbstractObserver {
|
||||
// //abstract
|
||||
// function new (): IAbstractObserver;
|
||||
//}
|
||||
}
|
||||
|
||||
interface IAnonymousObserver extends Internals.IAbstractObserver {
|
||||
_onNext: (value: any) =>void;
|
||||
_onError: (exception: any) =>void;
|
||||
_onCompleted: () =>void;
|
||||
}
|
||||
export module AnonymousObserver {
|
||||
function new (onNext: (value: any) =>void , onError: (exception: any) =>void , onCompleted: () =>void ): IAnonymousObserver;
|
||||
}
|
||||
|
||||
interface ICheckedObserver extends IObserver {
|
||||
_observer: IObserver;
|
||||
_state: number; // 0 - idle, 1 - busy, 2 - done
|
||||
checkAccess(): void;
|
||||
}
|
||||
|
||||
export module Internals {
|
||||
interface IScheduledObserver extends IAbstractObserver {
|
||||
scheduler: IScheduler;
|
||||
observer: IObserver;
|
||||
isAcquired: bool;
|
||||
hasFaulted: bool;
|
||||
//queue: { (value: any): void; (exception: any): void; (): void; }[];
|
||||
disposable: ISerialDisposable;
|
||||
|
||||
ensureActive(): void;
|
||||
}
|
||||
export module ScheduledObserver {
|
||||
function new (scheduler: IScheduler, observer: IObserver): IScheduledObserver;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
interface IObservable {
|
||||
_subscribe: (observer: IObserver) =>_IDisposable;
|
||||
|
||||
subscribe(observer: IObserver): _IDisposable;
|
||||
|
||||
finalValue(): IObservable;
|
||||
subscribe(onNext?: (value: any) =>void , onError?: (exception: any) =>void , onCompleted?: () =>void ): _IDisposable;
|
||||
toArray(): IObservable;
|
||||
|
||||
observeOn(scheduler: IScheduler): IObservable;
|
||||
subscribeOn(scheduler: IScheduler): IObservable;
|
||||
amb(rightSource: IObservable): IObservable;
|
||||
catchException(handler: (exception: any) =>IObservable): IObservable;
|
||||
catchException(second: IObservable): IObservable;
|
||||
combineLatest(second: IObservable, resultSelector: (v1: any, v2: any) =>any): IObservable;
|
||||
combineLatest(second: IObservable, third: IObservable, resultSelector: (v1: any, v2: any, v3: any) =>any): IObservable;
|
||||
combineLatest(second: IObservable, third: IObservable, fourth: IObservable, resultSelector: (v1: any, v2: any, v3: any, v4: any) =>any): IObservable;
|
||||
combineLatest(second: IObservable, third: IObservable, fourth: IObservable, fifth, IObservable, resultSelector: (v1: any, v2: any, v3: any, v4: any, v5: any) =>any): IObservable;
|
||||
combineLatest(...soucesAndResultSelector: any[]): IObservable;
|
||||
concat(...sources: IObservable[]): IObservable;
|
||||
concat(sources: IObservable[]): IObservable;
|
||||
concatIObservable(): IObservable;
|
||||
merge(maxConcurrent: number): IObservable;
|
||||
merge(other: IObservable): IObservable;
|
||||
mergeIObservable(): IObservable;
|
||||
onErrorResumeNext(second: IObservable): IObservable;
|
||||
skipUntil(other: IObservable): IObservable;
|
||||
switchLatest(): IObservable;
|
||||
takeUntil(other: IObservable): IObservable;
|
||||
zip(second: IObservable, resultSelector: (v1: any, v2: any) =>any): IObservable;
|
||||
zip(second: IObservable, third: IObservable, resultSelector: (v1: any, v2: any, v3: any) =>any): IObservable;
|
||||
zip(second: IObservable, third: IObservable, fourth: IObservable, resultSelector: (v1: any, v2: any, v3: any, v4: any) =>any): IObservable;
|
||||
zip(second: IObservable, third: IObservable, fourth: IObservable, fifth, IObservable, resultSelector: (v1: any, v2: any, v3: any, v4: any, v5: any) =>any): IObservable;
|
||||
zip(...soucesAndResultSelector: any[]): IObservable;
|
||||
zip(second: any[], resultSelector: (left: any, right: any) =>any): IObservable;
|
||||
asIObservable(): IObservable;
|
||||
bufferWithCount(count: number, skip?: number): IObservable;
|
||||
dematerialize(): IObservable;
|
||||
distinctUntilChanged(keySelector?: (value: any) =>any, comparer?: (x: any, y: any) =>bool): IObservable;
|
||||
doAction(observer: IObserver): IObservable;
|
||||
doAction(onNext: (value: any) => void , onError?: (exception: any) =>void , onCompleted?: () =>void ): IObservable;
|
||||
finallyAction(action: () =>void ): IObservable;
|
||||
ignoreElements(): IObservable;
|
||||
materialize(): IObservable;
|
||||
repeat(repeatCount?: number): IObservable;
|
||||
retry(retryCount?: number): IObservable;
|
||||
scan(seed: any, accumulator: (acc: any, value: any) =>any): IObservable;
|
||||
scan(accumulator: (acc: any, value: any) =>any): IObservable;
|
||||
skipLast(count: number): IObservable;
|
||||
startWith(...values: any[]): IObservable;
|
||||
startWith(scheduler: IScheduler, ...values: any[]): IObservable;
|
||||
takeLast(count: number, scheduler?: IScheduler): IObservable;
|
||||
takeLastBuffer(count: number): IObservable;
|
||||
windowWithCount(count: number, skip?: number): IObservable;
|
||||
defaultIfEmpty(defaultValue?: any): IObservable;
|
||||
distinct(keySelector?: (value: any) =>any, keySerializer?: (key: any) =>string): IObservable;
|
||||
groupBy(keySelector: (value: any) =>any, elementSelector?: (value: any) =>any, keySerializer?: (key: any) =>string): IGroupedObservable;
|
||||
groupByUntil(keySelector: (value: any) =>any, elementSelector: (value: any) =>any, durationSelector: (gloup: IGroupedObservable) =>IObservable, keySerializer?: (key: any) =>string): IGroupedObservable;
|
||||
select(selector: (value: any, index: number) =>any): IObservable;
|
||||
selectMany(selector: (value: any) =>IObservable, resultSelector?: (x: any, y: any) =>any): IObservable;
|
||||
selectMany(other: IObservable): IObservable;
|
||||
skip(count: number): IObservable;
|
||||
skipWhile(predicate: (value: any, index?: number) =>bool): IObservable;
|
||||
take(count: number, scheduler?: IScheduler): IObservable;
|
||||
takeWhile(predicate: (value: any, index?: number) =>bool): IObservable;
|
||||
where(predicate: (value: any, index?: number) => bool): IObservable;
|
||||
|
||||
// time
|
||||
delay(dueTime: number, scheduler?: IScheduler): IObservable;
|
||||
throttle(dueTime: number, scheduler?: IScheduler): IObservable;
|
||||
windowWithTime(dueTime: number, timeShiftOrScheduler?: any, scheduler?: IScheduler): IObservable;
|
||||
timeInterval(scheduler: IScheduler): IObservable;
|
||||
sample(interval: number, scheduler?: IScheduler): IObservable;
|
||||
sample(sampler: IObservable, scheduler?: IScheduler): IObservable;
|
||||
timeout(dueTime: number, other?: IObservable, scheduler?: IScheduler): IObservable;
|
||||
delaySubscription(dueTime: number, scheduler?: IScheduler): IObservable;
|
||||
}
|
||||
export module Observable {
|
||||
function new (subscribe: (observer: IObserver) =>_IDisposable): IObservable;
|
||||
|
||||
function start(func: () =>any, scheduler?: IScheduler, context?: any): IObservable;
|
||||
function toAsync(func: Function, scheduler?: IScheduler, context?: any): (...arguments: any[]) => IObservable;
|
||||
function create(subscribe: (Observer) =>() =>void ): IObservable;
|
||||
function createWithDisposable(subscribe: (Observer) =>_IDisposable): IObservable;
|
||||
function defer(observableFactory: () =>IObservable): IObservable;
|
||||
function empty(scheduler?: IScheduler): IObservable;
|
||||
function fromArray(array: any[], scheduler?: IScheduler): IObservable;
|
||||
function fromArray(array: { length: number;[index: number]: any; }, scheduler?: IScheduler): IObservable;
|
||||
function generate(initialState: any, condition: (state: any) =>bool, iterate: (state: any) =>any, resultSelector: (state: any) =>any, scheduler?: IScheduler): IObservable;
|
||||
function never(): IObservable;
|
||||
function range(start: number, count: number, scheduler?: IScheduler): IObservable;
|
||||
function repeat(value: any, repeatCount?: number, scheduler?: IScheduler): IObservable;
|
||||
function returnValue(value: any, scheduler?: IScheduler): IObservable;
|
||||
function throwException(exception: any, scheduler?: IScheduler): IObservable;
|
||||
function using(resourceFactory: () =>any, observableFactory: (resource: any) =>IObservable): IObservable;
|
||||
function amb(...sources: IObservable[]): IObservable;
|
||||
function catchException(sources: IObservable[]): IObservable;
|
||||
function catchException(...sources: IObservable[]): IObservable;
|
||||
function concat(...sources: IObservable[]): IObservable;
|
||||
function concat(sources: IObservable[]): IObservable;
|
||||
function merge(...sources: IObservable[]): IObservable;
|
||||
function merge(sources: IObservable[]): IObservable;
|
||||
function merge(scheduler: IScheduler, ...sources: IObservable[]): IObservable;
|
||||
function merge(scheduler: IScheduler, sources: IObservable[]): IObservable;
|
||||
function onErrorResumeNext(...sources: IObservable[]): IObservable;
|
||||
function onErrorResumeNext(sources: IObservable[]): IObservable;
|
||||
}
|
||||
|
||||
export module Internals {
|
||||
interface IAnonymousObservable extends IObservable { }
|
||||
export module AnonymousObservable {
|
||||
function new (subscribe: (observer: IObserver) =>_IDisposable): IAnonymousObservable;
|
||||
}
|
||||
}
|
||||
|
||||
interface IGroupedObservable extends IObservable {
|
||||
key: any;
|
||||
underlyingObservable: IObservable;
|
||||
}
|
||||
|
||||
interface ISubject extends IObservable, IObserver {
|
||||
isDisposed: bool;
|
||||
isStopped: bool;
|
||||
observers: IObserver[];
|
||||
|
||||
dispose(): void;
|
||||
}
|
||||
export module Subject {
|
||||
function new (): ISubject;
|
||||
|
||||
function create(observer: IObserver, observable: IObservable): ISubject;
|
||||
}
|
||||
|
||||
interface IAsyncSubject extends IObservable, IObserver {
|
||||
isDisposed: bool;
|
||||
value: any;
|
||||
hasValue: bool;
|
||||
observers: IObserver[];
|
||||
exception: any;
|
||||
|
||||
dispose(): void;
|
||||
}
|
||||
export module AsyncSubject {
|
||||
function new (): IAsyncSubject;
|
||||
}
|
||||
|
||||
interface IAnonymousSubject extends IObservable {
|
||||
onNext(value: any): void;
|
||||
onError(exception: any): void;
|
||||
onCompleted(): void;
|
||||
}
|
||||
}
|
||||
6
rx.js/rx.js.html.d.ts
vendored
Normal file
6
rx.js/rx.js.html.d.ts
vendored
Normal file
@@ -0,0 +1,6 @@
|
||||
declare module Rx {
|
||||
export module Observable {
|
||||
function fromEvent(element: HTMLElement, eventName: string) : IObservable;
|
||||
function fromEvent(document: HTMLDocument, eventName: string): IObservable;
|
||||
}
|
||||
}
|
||||
10
rx.js/rx.js.time.d.ts
vendored
Normal file
10
rx.js/rx.js.time.d.ts
vendored
Normal file
@@ -0,0 +1,10 @@
|
||||
///<reference path="rx.js.d.ts" />
|
||||
|
||||
declare module Rx {
|
||||
export module Observable {
|
||||
function ifThen(condition: () => bool, thenSource: IObservable): IObservable;
|
||||
function ifThen(condition: () => bool, thenSource: IObservable, elseSource: IObservable): IObservable;
|
||||
function ifThen(condition: () => bool, thenSource: IObservable, scheduler: IScheduler): IObservable;
|
||||
function interval(period: number, scheduler?: IScheduler): IObservable;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user