More RxJs definitions

Definitions for RxJs.html, RxJs.Time and RxJs.Aggregates

rx.js/rx.js.aggregates.d.ts

@@ -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;
+	}
+}

rx.js/rx.js.d.ts

@@ -298,7 +298,7 @@ declare module Rx {
             observer: IObserver;
             isAcquired: bool;
             hasFaulted: bool;
-            queue: { (value: any): void; (exception: any): void; (): void; }[];
+            //queue: { (value: any): void; (exception: any): void; (): void; }[];
             disposable: ISerialDisposable;
 
             ensureActive(): void;
@@ -374,7 +374,17 @@ declare module Rx {
         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;
+        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;

rx.js/rx.js.html.d.ts

@@ -0,0 +1,6 @@
+declare module Rx {
+	export module Observable {
+		function fromEvent(element: HTMLElement, eventName: string) : IObservable;
+		function fromEvent(document: HTMLDocument, eventName: string): IObservable;
+	}
+}

rx.js/rx.js.time.d.ts

@@ -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;
+	}
+}