Add tags for the family of Observable* types to simplify typechecking

src/Observable.ts

@@ -20,6 +20,7 @@ export type ObservableInput<T> = ObservableOrPromise<T> | ArrayOrIterator<T>;
  * @class Observable<T>
  */
 export class Observable<T> {
+  ' tag_class_Observable': T;
 
   public _isScalar: boolean = false;
 

src/Subject.ts

@@ -10,16 +10,20 @@ import {throwError} from './util/throwError';
 import {ObjectUnsubscribedError} from './util/ObjectUnsubscribedError';
 
 export class Subject<T> extends Observable<T> implements Observer<T>, Subscription {
+  ' tag_class_Subject': T;
 
   static create: Function = <T>(destination: Observer<T>, source: Observable<T>): Subject<T> => {
     return new Subject<T>(destination, source);
   };
 
-  constructor(protected destination?: Observer<T>, protected source?: Observable<T>) {
+  constructor(destination?: Observer<T>, source?: Observable<T>) {
     super();
+    this.destination = destination;
     this.source = source;
   }
 
+  protected destination: Observer<T>;
+  protected source: Observable<T>;
   public observers: Observer<T>[] = [];
   public isUnsubscribed: boolean = false;
 

src/observable/ArrayLikeObservable.ts

@@ -6,6 +6,7 @@ import {Subscriber} from '../Subscriber';
 import {Subscription} from '../Subscription';
 
 export class ArrayLikeObservable<T> extends Observable<T> {
+  ' tag_class_ArrayLikeObservable': T;
 
   private mapFn: (x: T, y: number) => T;
 

src/observable/ArrayObservable.ts

@@ -10,6 +10,7 @@ import {Subscription} from '../Subscription';
  *
  */
 export class ArrayObservable<T> extends Observable<T> {
+  ' tag_class_ArrayLikeObservable': T;
 
   /**
    * @param array

src/observable/BoundCallbackObservable.ts

@@ -10,6 +10,8 @@ import {AsyncSubject} from '../subject/AsyncSubject';
  *
  */
 export class BoundCallbackObservable<T> extends Observable<T> {
+  ' tag_class_BoundCallbackObservable': T;
+
   subject: AsyncSubject<T>;
 
   /* tslint:disable:max-line-length */

src/observable/BoundNodeCallbackObservable.ts

@@ -10,6 +10,8 @@ import {AsyncSubject} from '../subject/AsyncSubject';
  *
  */
 export class BoundNodeCallbackObservable<T> extends Observable<T> {
+  ' tag_class_BoundNodeCallbackObservable': T;
+
   subject: AsyncSubject<T>;
 
   /* tslint:disable:max-line-length */

src/observable/ConnectableObservable.ts

@@ -4,6 +4,7 @@ import {Subscriber} from '../Subscriber';
 import {Subscription} from '../Subscription';
 
 export class ConnectableObservable<T> extends Observable<T> {
+  ' tag_class_ConnectableObservable': T;
 
   protected subject: Subject<T>;
   protected subscription: Subscription;

src/observable/DeferObservable.ts

@@ -7,6 +7,7 @@ import {errorObject} from '../util/errorObject';
  *
  */
 export class DeferObservable<T> extends Observable<T> {
+  ' tag_class_DeferObservable': T;
 
   /**
    * @param observableFactory

src/observable/EmptyObservable.ts

@@ -7,6 +7,7 @@ import {Subscription} from '../Subscription';
  *
  */
 export class EmptyObservable<T> extends Observable<T> {
+  ' tag_class_EmptyObservable': T;
 
   /**
    * @param scheduler

src/observable/ErrorObservable.ts

@@ -6,6 +6,7 @@ import {Subscription} from '../Subscription';
  *
  */
 export class ErrorObservable extends Observable<any> {
+  ' tag_class_ErrorObservable': any;
 
   /**
    * @param error

src/observable/ForkJoinObservable.ts

@@ -9,6 +9,8 @@ import {isArray} from '../util/isArray';
  *
  */
 export class ForkJoinObservable<T> extends Observable<T> {
+  ' tag_class_ForkJoinObservable': T;
+
   constructor(private sources: Array<Observable<any> | Promise<any>>,
               private resultSelector?: (...values: Array<any>) => T) {
     super();

src/observable/FromEventObservable.ts

@@ -38,6 +38,7 @@ export type EventTargetLike = EventTarget | NodeStyleEventEmmitter | JQueryStyle
  *
  */
 export class FromEventObservable<T, R> extends Observable<T> {
+  ' tag_class_FromEventObservable': [T, R];
 
   /**
    * @param sourceObj

src/observable/FromEventPatternObservable.ts

@@ -8,6 +8,7 @@ import {Subscriber} from '../Subscriber';
  *
  */
 export class FromEventPatternObservable<T, R> extends Observable<T> {
+  ' tag_class_FromEventPatternObservable': [T, R];
 
   /**
    * @param addHandler

src/observable/FromObservable.ts

@@ -19,6 +19,8 @@ const isArrayLike = (<T>(x: any): x is ArrayLike<T> => x && typeof x.length ===
  *
  */
 export class FromObservable<T> extends Observable<T> {
+  ' tag_class_FromObservable': T;
+
   constructor(private ish: ObservableInput<T>, private scheduler: Scheduler) {
     super(null);
   }

src/observable/IfObservable.ts

@@ -3,6 +3,7 @@ import {Subscriber} from '../Subscriber';
 import {Subscription} from '../Subscription';
 
 export class IfObservable<T, R> extends Observable<T> {
+  ' tag_class_IfObservable': [T, R];
 
   static create<T, R>(condition: () => boolean,
                       thenSource?: Observable<T>,

src/observable/IntervalObservable.ts

@@ -8,6 +8,8 @@ import {async} from '../scheduler/async';
  *
  */
 export class IntervalObservable extends Observable<number> {
+  ' tag_class_IntervalObservable': any;
+
   /**
    * @param period
    * @param scheduler

src/observable/IteratorObservable.ts

@@ -10,6 +10,8 @@ import {Subscription} from '../Subscription';
 import {Subscriber} from '../Subscriber';
 
 export class IteratorObservable<T> extends Observable<T> {
+  ' tag_class_IteratorObservable': T;
+
   private iterator: any;
 
   static create<T>(iterator: any,

src/observable/NeverObservable.ts

@@ -6,6 +6,8 @@ import {noop} from '../util/noop';
  *
  */
 export class NeverObservable<T> extends Observable<T> {
+  ' tag_class_NeverObservable': T;
+
   /**
    * @return {NeverObservable<T>}
    * @static true

src/observable/PromiseObservable.ts

@@ -8,6 +8,7 @@ import {Subscription} from '../Subscription';
  *
  */
 export class PromiseObservable<T> extends Observable<T> {
+  ' tag_class_PromiseObservable': T;
 
   public value: T;
 

src/observable/RangeObservable.ts

@@ -7,6 +7,7 @@ import {Subscriber} from '../Subscriber';
  *
  */
 export class RangeObservable extends Observable<number> {
+  ' tag_class_RangeObservable': any;
 
   /**
    * @param start

src/observable/ScalarObservable.ts

@@ -4,6 +4,8 @@ import {Subscriber} from '../Subscriber';
 import {Subscription} from '../Subscription';
 
 export class ScalarObservable<T> extends Observable<T> {
+  ' tag_class_ScalarObservable': T;
+
   static create<T>(value: T, scheduler?: Scheduler): ScalarObservable<T> {
     return new ScalarObservable(value, scheduler);
   }

src/observable/SubscribeOnObservable.ts

@@ -6,6 +6,8 @@ import {asap} from '../scheduler/asap';
 import {isNumeric} from '../util/isNumeric';
 
 export class SubscribeOnObservable<T> extends Observable<T> {
+  ' tag_class_SubscribeOnObservable': T;
+
   static create<T>(source: Observable<T>, delay: number = 0, scheduler: Scheduler = asap): Observable<T> {
     return new SubscribeOnObservable(source, delay, scheduler);
   }

src/observable/TimerObservable.ts

@@ -11,6 +11,7 @@ import {Subscriber} from '../Subscriber';
  *
  */
 export class TimerObservable extends Observable<number> {
+  ' tag_class_TimerObservable': any;
 
   /**
    * @param dueTime

src/observable/UsingObservable.ts

@@ -3,6 +3,7 @@ import {Subscriber} from '../Subscriber';
 import {Subscription} from '../Subscription';
 
 export class UsingObservable<T> extends Observable<T> {
+  ' tag_class_UsingObservable': T;
 
   static create<T>(resourceFactory: () => Subscription,
                    observableFactory: (resource: Subscription) => Observable<T>): Observable<T> {

src/subject/AsyncSubject.ts

@@ -3,6 +3,8 @@ import {Subscriber} from '../Subscriber';
 import {Subscription} from '../Subscription';
 
 export class AsyncSubject<T> extends Subject<T> {
+  ' tag_class_AsyncSubject': T;
+
   value: T = null;
   hasNext: boolean = false;
 

src/subject/BehaviorSubject.ts

@@ -5,6 +5,7 @@ import {throwError} from '../util/throwError';
 import {ObjectUnsubscribedError} from '../util/ObjectUnsubscribedError';
 
 export class BehaviorSubject<T> extends Subject<T> {
+  ' tag_class_BehaviorSubject': T;
 
   constructor(private _value: T) {
     super();

src/subject/ReplaySubject.ts

@@ -6,6 +6,8 @@ import {Subscription} from '../Subscription';
 import {ObserveOnSubscriber} from '../operator/observeOn';
 
 export class ReplaySubject<T> extends Subject<T> {
+  ' tag_class_ReplaySubject': T;
+
   private events: ReplayEvent<T>[] = [];
   private scheduler: Scheduler;
   private bufferSize: number;