Fixes in rebuild-ts grunt task.

rebuild-ts task would wrongly exclude typings included in the rx.lite.d.ts
file. For instance would rx.time.d.ts only receive the typings not
included in rx.lite.d.ts.

As it was, I could only use either rx.lite.d.ts or rx.all.d.ts. However,
I use a subset with rx.d.ts, rx.binding.ts and rx.time.d.ts. This fix
makes it possible to do that. Instead of excluding typings included in
lite, the rebuild-ts task now correctly excludes typings included in main
(rx.d.ts). The original behaviour is kept if lite typings are built. I
believe this is the correct behaviour, and it works nicely in my setup. I
can now use a subset of the typings.

I've also fixed the declare module output of rx.d.ts. It would previously
add the declare module "rx" line twice, resulting in a compiler error when
included in a project.

Author: Dan Lewi Harkestad

Gruntfile.js

@@ -2619,7 +2619,9 @@ module.exports = function (grunt) {
       }
 
 	  if (!(concatKey === 'all' || concatKey === 'main' || concatKey === 'lite' || concatKey === 'core')) {
-		if (allLoadedFiles['lite'][tsFile] || allLoadedFiles['core'][tsFile]) {
+		if ((concatKey.indexOf('lite') === 0 && allLoadedFiles['lite'][tsFile])
+		    || (concatKey.indexOf('lite') !== 0 && allLoadedFiles['main'][tsFile])
+		    || allLoadedFiles['core'][tsFile]) {
 		  loadedFiles[tsFile] = true;
 		  return;
 		}
@@ -2655,7 +2657,7 @@ module.exports = function (grunt) {
 	    continue;
 	  }
 
-	  if (key === 'lite' || key === 'core') {
+	  if (key === 'lite' || key === 'main' || key === 'core') {
 		items.unshift(key);
 	  } else {
 		items.push(key);
@@ -2717,7 +2719,7 @@ module.exports = function (grunt) {
 		if (concatKey === 'all' || concatKey === 'main' || concatKey === 'lite' || concatKey === 'core') {
 		  outputString += '\ndeclare module "rx" { export = Rx; }\n';
 		}
-		if (dist && concatKey !== 'core') {
+		if (dist && concatKey !== 'core' && concatKey !== 'main') {
 		  outputString += 'declare module "'+dist+'" { export = Rx; }';
 		}
 

ts/rx.async.d.ts

@@ -1,5 +1,67 @@
 declare module Rx {
 
+    /**
+    * Used to pause and resume streams.
+    */
+    export interface Pauser {
+        /**
+         * Pauses the underlying sequence.
+         */
+        pause(): void;
+
+        /**
+        * Resumes the underlying sequence.
+        */
+        resume(): void;
+    }
+
+    export interface Observable<T> {
+        /**
+         * Pauses the underlying observable sequence based upon the observable sequence which yields true/false.
+         * @example
+         * var pauser = new Rx.Subject();
+         * var source = Rx.Observable.interval(100).pausable(pauser);
+         * @param {Observable} pauser The observable sequence used to pause the underlying sequence.
+         * @returns {Observable} The observable sequence which is paused based upon the pauser.
+         */
+        pausable(pauser?: Observable<boolean>): PausableObservable<T>;
+    }
+
+    export interface PausableObservable<T> extends Observable<T> {
+        pause(): void;
+        resume(): void;
+    }
+
+    export interface Observable<T> {
+        /**
+         * Pauses the underlying observable sequence based upon the observable sequence which yields true/false,
+         * and yields the values that were buffered while paused.
+         * @example
+         * var pauser = new Rx.Subject();
+         * var source = Rx.Observable.interval(100).pausableBuffered(pauser);
+         * @param {Observable} pauser The observable sequence used to pause the underlying sequence.
+         * @returns {Observable} The observable sequence which is paused based upon the pauser.
+         */
+        pausableBuffered(pauser?: Observable<boolean>): PausableObservable<T>;
+    }
+
+    export interface Observable<T> {
+        /**
+        * Attaches a controller to the observable sequence with the ability to queue.
+        * @example
+        * var source = Rx.Observable.interval(100).controlled();
+        * source.request(3); // Reads 3 values
+        * @param {bool} enableQueue truthy value to determine if values should be queued pending the next request
+        * @param {Scheduler} scheduler determines how the requests will be scheduled
+        * @returns {Observable} The observable sequence which only propagates values on request.
+        */
+        controlled(enableQueue?: boolean, scheduler?: IScheduler): ControlledObservable<T>;
+    }
+
+    export interface ControlledObservable<T> extends Observable<T> {
+        request(numberOfItems?: number): IDisposable;
+    }
+
     export interface ControlledObservable<T> {
         /**
          * Attaches a stop and wait observable to the current observable.
@@ -17,5 +79,15 @@ declare module Rx {
         windowed(windowSize: number): Observable<T>;
     }
 
+    export interface Observable<T> {
+        /**
+        * Pipes the existing Observable sequence into a Node.js Stream.
+        * @param {Stream} dest The destination Node.js stream.
+        * @returns {Stream} The destination stream.
+        */
+        pipe<TDest>(dest: TDest): TDest;
+        // TODO: Add link to node.d.ts some where
+    }
+
 }
 declare module "rx.backpressure" { export = Rx; }

ts/rx.async.es6.d.ts

@@ -1,5 +1,67 @@
 declare module Rx {
 
+    /**
+    * Used to pause and resume streams.
+    */
+    export interface Pauser {
+        /**
+         * Pauses the underlying sequence.
+         */
+        pause(): void;
+
+        /**
+        * Resumes the underlying sequence.
+        */
+        resume(): void;
+    }
+
+    export interface Observable<T> {
+        /**
+         * Pauses the underlying observable sequence based upon the observable sequence which yields true/false.
+         * @example
+         * var pauser = new Rx.Subject();
+         * var source = Rx.Observable.interval(100).pausable(pauser);
+         * @param {Observable} pauser The observable sequence used to pause the underlying sequence.
+         * @returns {Observable} The observable sequence which is paused based upon the pauser.
+         */
+        pausable(pauser?: Observable<boolean>): PausableObservable<T>;
+    }
+
+    export interface PausableObservable<T> extends Observable<T> {
+        pause(): void;
+        resume(): void;
+    }
+
+    export interface Observable<T> {
+        /**
+         * Pauses the underlying observable sequence based upon the observable sequence which yields true/false,
+         * and yields the values that were buffered while paused.
+         * @example
+         * var pauser = new Rx.Subject();
+         * var source = Rx.Observable.interval(100).pausableBuffered(pauser);
+         * @param {Observable} pauser The observable sequence used to pause the underlying sequence.
+         * @returns {Observable} The observable sequence which is paused based upon the pauser.
+         */
+        pausableBuffered(pauser?: Observable<boolean>): PausableObservable<T>;
+    }
+
+    export interface Observable<T> {
+        /**
+        * Attaches a controller to the observable sequence with the ability to queue.
+        * @example
+        * var source = Rx.Observable.interval(100).controlled();
+        * source.request(3); // Reads 3 values
+        * @param {bool} enableQueue truthy value to determine if values should be queued pending the next request
+        * @param {Scheduler} scheduler determines how the requests will be scheduled
+        * @returns {Observable} The observable sequence which only propagates values on request.
+        */
+        controlled(enableQueue?: boolean, scheduler?: IScheduler): ControlledObservable<T>;
+    }
+
+    export interface ControlledObservable<T> extends Observable<T> {
+        request(numberOfItems?: number): IDisposable;
+    }
+
     export interface ControlledObservable<T> {
         /**
          * Attaches a stop and wait observable to the current observable.
@@ -17,5 +79,15 @@ declare module Rx {
         windowed(windowSize: number): Observable<T>;
     }
 
+    export interface Observable<T> {
+        /**
+        * Pipes the existing Observable sequence into a Node.js Stream.
+        * @param {Stream} dest The destination Node.js stream.
+        * @returns {Stream} The destination stream.
+        */
+        pipe<TDest>(dest: TDest): TDest;
+        // TODO: Add link to node.d.ts some where
+    }
+
 }
 declare module "rx.backpressure" { export = Rx; }