From fcc06b45caf3d9d5a339ac275b2bf1791b716e03 Mon Sep 17 00:00:00 2001 From: Vladimir Matveev Date: Fri, 11 Mar 2016 13:30:41 -0800 Subject: [PATCH 1/4] fix(all): tag Observable/Subject type --- src/Observable.ts | 1 + src/Subject.ts | 1 + src/observable/ArrayLikeObservable.ts | 1 + src/observable/ArrayObservable.ts | 1 + src/observable/BoundCallbackObservable.ts | 2 ++ src/observable/BoundNodeCallbackObservable.ts | 2 ++ src/observable/ConnectableObservable.ts | 1 + src/observable/DeferObservable.ts | 1 + src/observable/EmptyObservable.ts | 1 + src/observable/ErrorObservable.ts | 1 + src/observable/ForkJoinObservable.ts | 2 ++ src/observable/FromEventObservable.ts | 1 + src/observable/FromEventPatternObservable.ts | 1 + src/observable/FromObservable.ts | 2 ++ src/observable/IfObservable.ts | 1 + src/observable/IntervalObservable.ts | 2 ++ src/observable/IteratorObservable.ts | 2 ++ src/observable/NeverObservable.ts | 2 ++ src/observable/PromiseObservable.ts | 1 + src/observable/RangeObservable.ts | 1 + src/observable/ScalarObservable.ts | 2 ++ src/observable/SubscribeOnObservable.ts | 2 ++ src/observable/TimerObservable.ts | 1 + src/observable/UsingObservable.ts | 1 + src/subject/AsyncSubject.ts | 2 ++ src/subject/BehaviorSubject.ts | 1 + src/subject/ReplaySubject.ts | 2 ++ 27 files changed, 38 insertions(+) diff --git a/src/Observable.ts b/src/Observable.ts index 8de30e816c..0f42ba6f28 100644 --- a/src/Observable.ts +++ b/src/Observable.ts @@ -20,6 +20,7 @@ export type ObservableInput = ObservableOrPromise | ArrayOrIterator; * @class Observable */ export class Observable { + " tag_class_Observable": T; public _isScalar: boolean = false; diff --git a/src/Subject.ts b/src/Subject.ts index c7ea22f3ad..1df4a3adde 100644 --- a/src/Subject.ts +++ b/src/Subject.ts @@ -10,6 +10,7 @@ import {throwError} from './util/throwError'; import {ObjectUnsubscribedError} from './util/ObjectUnsubscribedError'; export class Subject extends Observable implements Observer, Subscription { + " tag_class_Subject": T; static create: Function = (destination: Observer, source: Observable): Subject => { return new Subject(destination, source); diff --git a/src/observable/ArrayLikeObservable.ts b/src/observable/ArrayLikeObservable.ts index 926b849654..1c5444bd45 100644 --- a/src/observable/ArrayLikeObservable.ts +++ b/src/observable/ArrayLikeObservable.ts @@ -6,6 +6,7 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class ArrayLikeObservable extends Observable { + " tag_class_ArrayLikeObservable": T; private mapFn: (x: T, y: number) => T; diff --git a/src/observable/ArrayObservable.ts b/src/observable/ArrayObservable.ts index 32248bf8da..3d77b386a2 100644 --- a/src/observable/ArrayObservable.ts +++ b/src/observable/ArrayObservable.ts @@ -10,6 +10,7 @@ import {Subscription} from '../Subscription'; * */ export class ArrayObservable extends Observable { + "tag_class_ArrayLikeObservable": T; /** * @param array diff --git a/src/observable/BoundCallbackObservable.ts b/src/observable/BoundCallbackObservable.ts index b5a3d5b4b6..0d91a1bf62 100644 --- a/src/observable/BoundCallbackObservable.ts +++ b/src/observable/BoundCallbackObservable.ts @@ -10,6 +10,8 @@ import {AsyncSubject} from '../subject/AsyncSubject'; * */ export class BoundCallbackObservable extends Observable { + "tag_class_BoundCallbackObservable": T; + subject: AsyncSubject; /* tslint:disable:max-line-length */ diff --git a/src/observable/BoundNodeCallbackObservable.ts b/src/observable/BoundNodeCallbackObservable.ts index 55b46d4185..9bf575010f 100644 --- a/src/observable/BoundNodeCallbackObservable.ts +++ b/src/observable/BoundNodeCallbackObservable.ts @@ -10,6 +10,8 @@ import {AsyncSubject} from '../subject/AsyncSubject'; * */ export class BoundNodeCallbackObservable extends Observable { + " tag_class_BoundNodeCallbackObservable": T; + subject: AsyncSubject; /* tslint:disable:max-line-length */ diff --git a/src/observable/ConnectableObservable.ts b/src/observable/ConnectableObservable.ts index b353574fd6..070f85a6c5 100644 --- a/src/observable/ConnectableObservable.ts +++ b/src/observable/ConnectableObservable.ts @@ -4,6 +4,7 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class ConnectableObservable extends Observable { + " tag_class_ConnectableObservable": T; protected subject: Subject; protected subscription: Subscription; diff --git a/src/observable/DeferObservable.ts b/src/observable/DeferObservable.ts index cebc595499..0879d5941d 100644 --- a/src/observable/DeferObservable.ts +++ b/src/observable/DeferObservable.ts @@ -7,6 +7,7 @@ import {errorObject} from '../util/errorObject'; * */ export class DeferObservable extends Observable { + " tag_class_DeferObservable": T; /** * @param observableFactory diff --git a/src/observable/EmptyObservable.ts b/src/observable/EmptyObservable.ts index 160f1f8424..91164d891c 100644 --- a/src/observable/EmptyObservable.ts +++ b/src/observable/EmptyObservable.ts @@ -7,6 +7,7 @@ import {Subscription} from '../Subscription'; * */ export class EmptyObservable extends Observable { + " tag_class_EmptyObservable": T; /** * @param scheduler diff --git a/src/observable/ErrorObservable.ts b/src/observable/ErrorObservable.ts index 43663fb99b..7c884120a8 100644 --- a/src/observable/ErrorObservable.ts +++ b/src/observable/ErrorObservable.ts @@ -6,6 +6,7 @@ import {Subscription} from '../Subscription'; * */ export class ErrorObservable extends Observable { + " tag_class_ErrorObservable": any; /** * @param error diff --git a/src/observable/ForkJoinObservable.ts b/src/observable/ForkJoinObservable.ts index ce8539a4e8..3a10138a8c 100644 --- a/src/observable/ForkJoinObservable.ts +++ b/src/observable/ForkJoinObservable.ts @@ -9,6 +9,8 @@ import {isArray} from '../util/isArray'; * */ export class ForkJoinObservable extends Observable { + " tag_class_ForkJoinObservable": T; + constructor(private sources: Array | Promise>, private resultSelector?: (...values: Array) => T) { super(); diff --git a/src/observable/FromEventObservable.ts b/src/observable/FromEventObservable.ts index 50d8175c92..c1b9c5fbad 100644 --- a/src/observable/FromEventObservable.ts +++ b/src/observable/FromEventObservable.ts @@ -38,6 +38,7 @@ export type EventTargetLike = EventTarget | NodeStyleEventEmmitter | JQueryStyle * */ export class FromEventObservable extends Observable { + " tag_class_FromEventObservable": [T, R]; /** * @param sourceObj diff --git a/src/observable/FromEventPatternObservable.ts b/src/observable/FromEventPatternObservable.ts index 20f70d8bea..2dcce76622 100644 --- a/src/observable/FromEventPatternObservable.ts +++ b/src/observable/FromEventPatternObservable.ts @@ -8,6 +8,7 @@ import {Subscriber} from '../Subscriber'; * */ export class FromEventPatternObservable extends Observable { + " tag_class_FromEventPatternObservable": [T, R]; /** * @param addHandler diff --git a/src/observable/FromObservable.ts b/src/observable/FromObservable.ts index 945fee1467..1faa068103 100644 --- a/src/observable/FromObservable.ts +++ b/src/observable/FromObservable.ts @@ -19,6 +19,8 @@ const isArrayLike = ((x: any): x is ArrayLike => x && typeof x.length === * */ export class FromObservable extends Observable { + " tag_class_FromObservable": T; + constructor(private ish: ObservableInput, private scheduler: Scheduler) { super(null); } diff --git a/src/observable/IfObservable.ts b/src/observable/IfObservable.ts index c12ba85be1..c6c4de8938 100644 --- a/src/observable/IfObservable.ts +++ b/src/observable/IfObservable.ts @@ -3,6 +3,7 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class IfObservable extends Observable { + " tag_class_IfObservable": [T, R]; static create(condition: () => boolean, thenSource?: Observable, diff --git a/src/observable/IntervalObservable.ts b/src/observable/IntervalObservable.ts index cf3cdda5d6..9931e73996 100644 --- a/src/observable/IntervalObservable.ts +++ b/src/observable/IntervalObservable.ts @@ -8,6 +8,8 @@ import {async} from '../scheduler/async'; * */ export class IntervalObservable extends Observable { + " tag_class_IntervalObservable": any; + /** * @param period * @param scheduler diff --git a/src/observable/IteratorObservable.ts b/src/observable/IteratorObservable.ts index e9390d9c8c..930a16ffe3 100644 --- a/src/observable/IteratorObservable.ts +++ b/src/observable/IteratorObservable.ts @@ -10,6 +10,8 @@ import {Subscription} from '../Subscription'; import {Subscriber} from '../Subscriber'; export class IteratorObservable extends Observable { + " tag_class_IteratorObservable": T; + private iterator: any; static create(iterator: any, diff --git a/src/observable/NeverObservable.ts b/src/observable/NeverObservable.ts index 373f6749b8..1b50079bf0 100644 --- a/src/observable/NeverObservable.ts +++ b/src/observable/NeverObservable.ts @@ -6,6 +6,8 @@ import {noop} from '../util/noop'; * */ export class NeverObservable extends Observable { + " tag_class_NeverObservable": T; + /** * @return {NeverObservable} * @static true diff --git a/src/observable/PromiseObservable.ts b/src/observable/PromiseObservable.ts index d7a6ed4c0a..d6ecb25444 100644 --- a/src/observable/PromiseObservable.ts +++ b/src/observable/PromiseObservable.ts @@ -8,6 +8,7 @@ import {Subscription} from '../Subscription'; * */ export class PromiseObservable extends Observable { + " tag_class_PromiseObservable": T; public value: T; diff --git a/src/observable/RangeObservable.ts b/src/observable/RangeObservable.ts index 05919fa23e..434d95f3c0 100644 --- a/src/observable/RangeObservable.ts +++ b/src/observable/RangeObservable.ts @@ -7,6 +7,7 @@ import {Subscriber} from '../Subscriber'; * */ export class RangeObservable extends Observable { + " tag_class_RangeObservable": any; /** * @param start diff --git a/src/observable/ScalarObservable.ts b/src/observable/ScalarObservable.ts index e7b5c6801f..4c5d27c3ed 100644 --- a/src/observable/ScalarObservable.ts +++ b/src/observable/ScalarObservable.ts @@ -4,6 +4,8 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class ScalarObservable extends Observable { + " tag_class_ScalarObservable": T; + static create(value: T, scheduler?: Scheduler): ScalarObservable { return new ScalarObservable(value, scheduler); } diff --git a/src/observable/SubscribeOnObservable.ts b/src/observable/SubscribeOnObservable.ts index 3919f1a646..31b30d36e4 100644 --- a/src/observable/SubscribeOnObservable.ts +++ b/src/observable/SubscribeOnObservable.ts @@ -6,6 +6,8 @@ import {asap} from '../scheduler/asap'; import {isNumeric} from '../util/isNumeric'; export class SubscribeOnObservable extends Observable { + " tag_class_SubscribeOnObservable": T; + static create(source: Observable, delay: number = 0, scheduler: Scheduler = asap): Observable { return new SubscribeOnObservable(source, delay, scheduler); } diff --git a/src/observable/TimerObservable.ts b/src/observable/TimerObservable.ts index 3db92b49c5..e0cd07d8a9 100644 --- a/src/observable/TimerObservable.ts +++ b/src/observable/TimerObservable.ts @@ -11,6 +11,7 @@ import {Subscriber} from '../Subscriber'; * */ export class TimerObservable extends Observable { + " tag_class_TimerObservable": any; /** * @param dueTime diff --git a/src/observable/UsingObservable.ts b/src/observable/UsingObservable.ts index a7b2ca941d..f7f92e0f6d 100644 --- a/src/observable/UsingObservable.ts +++ b/src/observable/UsingObservable.ts @@ -3,6 +3,7 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class UsingObservable extends Observable { + " tag_class_UsingObservable": T; static create(resourceFactory: () => Subscription, observableFactory: (resource: Subscription) => Observable): Observable { diff --git a/src/subject/AsyncSubject.ts b/src/subject/AsyncSubject.ts index 3a8bb4f487..9884254401 100644 --- a/src/subject/AsyncSubject.ts +++ b/src/subject/AsyncSubject.ts @@ -3,6 +3,8 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class AsyncSubject extends Subject { + " tag_class_AsyncSubject": T; + value: T = null; hasNext: boolean = false; diff --git a/src/subject/BehaviorSubject.ts b/src/subject/BehaviorSubject.ts index f39367e5c1..6e425049d7 100644 --- a/src/subject/BehaviorSubject.ts +++ b/src/subject/BehaviorSubject.ts @@ -5,6 +5,7 @@ import {throwError} from '../util/throwError'; import {ObjectUnsubscribedError} from '../util/ObjectUnsubscribedError'; export class BehaviorSubject extends Subject { + " tag_class_BehaviorSubject": T; constructor(private _value: T) { super(); diff --git a/src/subject/ReplaySubject.ts b/src/subject/ReplaySubject.ts index f50cda0ff6..f4fae44a28 100644 --- a/src/subject/ReplaySubject.ts +++ b/src/subject/ReplaySubject.ts @@ -6,6 +6,8 @@ import {Subscription} from '../Subscription'; import {ObserveOnSubscriber} from '../operator/observeOn'; export class ReplaySubject extends Subject { + " tag_class_ReplaySubject": T; + private events: ReplayEvent[] = []; private scheduler: Scheduler; private bufferSize: number; From 24155b52ad02250269f77114fa612bfb27d4ae09 Mon Sep 17 00:00:00 2001 From: Vladimir Matveev Date: Fri, 11 Mar 2016 16:33:56 -0800 Subject: [PATCH 2/4] fix(all): add leading space to tag properties to prevent them from popping up in completion --- src/observable/ArrayObservable.ts | 2 +- src/observable/BoundCallbackObservable.ts | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/observable/ArrayObservable.ts b/src/observable/ArrayObservable.ts index 3d77b386a2..6dc57bada3 100644 --- a/src/observable/ArrayObservable.ts +++ b/src/observable/ArrayObservable.ts @@ -10,7 +10,7 @@ import {Subscription} from '../Subscription'; * */ export class ArrayObservable extends Observable { - "tag_class_ArrayLikeObservable": T; + " tag_class_ArrayLikeObservable": T; /** * @param array diff --git a/src/observable/BoundCallbackObservable.ts b/src/observable/BoundCallbackObservable.ts index 0d91a1bf62..985f14ae95 100644 --- a/src/observable/BoundCallbackObservable.ts +++ b/src/observable/BoundCallbackObservable.ts @@ -10,7 +10,7 @@ import {AsyncSubject} from '../subject/AsyncSubject'; * */ export class BoundCallbackObservable extends Observable { - "tag_class_BoundCallbackObservable": T; + " tag_class_BoundCallbackObservable": T; subject: AsyncSubject; From a57d3b06ffccb01b7d1ede8e9aaf4383b5a8526b Mon Sep 17 00:00:00 2001 From: Vladimir Matveev Date: Mon, 14 Mar 2016 10:39:26 -0700 Subject: [PATCH 3/4] fix(Subject): switch parameter properties to regular properties --- src/Subject.ts | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/Subject.ts b/src/Subject.ts index 1df4a3adde..6e094c6592 100644 --- a/src/Subject.ts +++ b/src/Subject.ts @@ -16,11 +16,14 @@ export class Subject extends Observable implements Observer, Subscripti return new Subject(destination, source); }; - constructor(protected destination?: Observer, protected source?: Observable) { + constructor(destination?: Observer, source?: Observable) { super(); + this.destination = destination; this.source = source; } + protected destination: Observer; + protected source: Observable public observers: Observer[] = []; public isUnsubscribed: boolean = false; From f27ab2aa7756cc02230a69618d2f456b5a423529 Mon Sep 17 00:00:00 2001 From: Vladimir Matveev Date: Tue, 15 Mar 2016 10:34:26 -0700 Subject: [PATCH 4/4] fix(all): fix linter issues --- src/Observable.ts | 2 +- src/Subject.ts | 4 ++-- src/observable/ArrayLikeObservable.ts | 2 +- src/observable/ArrayObservable.ts | 2 +- src/observable/BoundCallbackObservable.ts | 2 +- src/observable/BoundNodeCallbackObservable.ts | 2 +- src/observable/ConnectableObservable.ts | 2 +- src/observable/DeferObservable.ts | 2 +- src/observable/EmptyObservable.ts | 2 +- src/observable/ErrorObservable.ts | 2 +- src/observable/ForkJoinObservable.ts | 2 +- src/observable/FromEventObservable.ts | 2 +- src/observable/FromEventPatternObservable.ts | 2 +- src/observable/FromObservable.ts | 2 +- src/observable/IfObservable.ts | 2 +- src/observable/IntervalObservable.ts | 2 +- src/observable/IteratorObservable.ts | 2 +- src/observable/NeverObservable.ts | 2 +- src/observable/PromiseObservable.ts | 2 +- src/observable/RangeObservable.ts | 2 +- src/observable/ScalarObservable.ts | 2 +- src/observable/SubscribeOnObservable.ts | 2 +- src/observable/TimerObservable.ts | 2 +- src/observable/UsingObservable.ts | 2 +- src/subject/AsyncSubject.ts | 2 +- src/subject/BehaviorSubject.ts | 2 +- src/subject/ReplaySubject.ts | 4 ++-- 27 files changed, 29 insertions(+), 29 deletions(-) diff --git a/src/Observable.ts b/src/Observable.ts index 0f42ba6f28..8cceaa04d7 100644 --- a/src/Observable.ts +++ b/src/Observable.ts @@ -20,7 +20,7 @@ export type ObservableInput = ObservableOrPromise | ArrayOrIterator; * @class Observable */ export class Observable { - " tag_class_Observable": T; + ' tag_class_Observable': T; public _isScalar: boolean = false; diff --git a/src/Subject.ts b/src/Subject.ts index 6e094c6592..d647d36837 100644 --- a/src/Subject.ts +++ b/src/Subject.ts @@ -10,7 +10,7 @@ import {throwError} from './util/throwError'; import {ObjectUnsubscribedError} from './util/ObjectUnsubscribedError'; export class Subject extends Observable implements Observer, Subscription { - " tag_class_Subject": T; + ' tag_class_Subject': T; static create: Function = (destination: Observer, source: Observable): Subject => { return new Subject(destination, source); @@ -23,7 +23,7 @@ export class Subject extends Observable implements Observer, Subscripti } protected destination: Observer; - protected source: Observable + protected source: Observable; public observers: Observer[] = []; public isUnsubscribed: boolean = false; diff --git a/src/observable/ArrayLikeObservable.ts b/src/observable/ArrayLikeObservable.ts index 1c5444bd45..55f1c1d7b3 100644 --- a/src/observable/ArrayLikeObservable.ts +++ b/src/observable/ArrayLikeObservable.ts @@ -6,7 +6,7 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class ArrayLikeObservable extends Observable { - " tag_class_ArrayLikeObservable": T; + ' tag_class_ArrayLikeObservable': T; private mapFn: (x: T, y: number) => T; diff --git a/src/observable/ArrayObservable.ts b/src/observable/ArrayObservable.ts index 6dc57bada3..87071fe6ef 100644 --- a/src/observable/ArrayObservable.ts +++ b/src/observable/ArrayObservable.ts @@ -10,7 +10,7 @@ import {Subscription} from '../Subscription'; * */ export class ArrayObservable extends Observable { - " tag_class_ArrayLikeObservable": T; + ' tag_class_ArrayLikeObservable': T; /** * @param array diff --git a/src/observable/BoundCallbackObservable.ts b/src/observable/BoundCallbackObservable.ts index 985f14ae95..1652dca2d3 100644 --- a/src/observable/BoundCallbackObservable.ts +++ b/src/observable/BoundCallbackObservable.ts @@ -10,7 +10,7 @@ import {AsyncSubject} from '../subject/AsyncSubject'; * */ export class BoundCallbackObservable extends Observable { - " tag_class_BoundCallbackObservable": T; + ' tag_class_BoundCallbackObservable': T; subject: AsyncSubject; diff --git a/src/observable/BoundNodeCallbackObservable.ts b/src/observable/BoundNodeCallbackObservable.ts index 9bf575010f..14defe87be 100644 --- a/src/observable/BoundNodeCallbackObservable.ts +++ b/src/observable/BoundNodeCallbackObservable.ts @@ -10,7 +10,7 @@ import {AsyncSubject} from '../subject/AsyncSubject'; * */ export class BoundNodeCallbackObservable extends Observable { - " tag_class_BoundNodeCallbackObservable": T; + ' tag_class_BoundNodeCallbackObservable': T; subject: AsyncSubject; diff --git a/src/observable/ConnectableObservable.ts b/src/observable/ConnectableObservable.ts index 070f85a6c5..f378850e54 100644 --- a/src/observable/ConnectableObservable.ts +++ b/src/observable/ConnectableObservable.ts @@ -4,7 +4,7 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class ConnectableObservable extends Observable { - " tag_class_ConnectableObservable": T; + ' tag_class_ConnectableObservable': T; protected subject: Subject; protected subscription: Subscription; diff --git a/src/observable/DeferObservable.ts b/src/observable/DeferObservable.ts index 0879d5941d..c7598ae641 100644 --- a/src/observable/DeferObservable.ts +++ b/src/observable/DeferObservable.ts @@ -7,7 +7,7 @@ import {errorObject} from '../util/errorObject'; * */ export class DeferObservable extends Observable { - " tag_class_DeferObservable": T; + ' tag_class_DeferObservable': T; /** * @param observableFactory diff --git a/src/observable/EmptyObservable.ts b/src/observable/EmptyObservable.ts index 91164d891c..4dc3580af8 100644 --- a/src/observable/EmptyObservable.ts +++ b/src/observable/EmptyObservable.ts @@ -7,7 +7,7 @@ import {Subscription} from '../Subscription'; * */ export class EmptyObservable extends Observable { - " tag_class_EmptyObservable": T; + ' tag_class_EmptyObservable': T; /** * @param scheduler diff --git a/src/observable/ErrorObservable.ts b/src/observable/ErrorObservable.ts index 7c884120a8..866b461437 100644 --- a/src/observable/ErrorObservable.ts +++ b/src/observable/ErrorObservable.ts @@ -6,7 +6,7 @@ import {Subscription} from '../Subscription'; * */ export class ErrorObservable extends Observable { - " tag_class_ErrorObservable": any; + ' tag_class_ErrorObservable': any; /** * @param error diff --git a/src/observable/ForkJoinObservable.ts b/src/observable/ForkJoinObservable.ts index 3a10138a8c..7fdabdf7e9 100644 --- a/src/observable/ForkJoinObservable.ts +++ b/src/observable/ForkJoinObservable.ts @@ -9,7 +9,7 @@ import {isArray} from '../util/isArray'; * */ export class ForkJoinObservable extends Observable { - " tag_class_ForkJoinObservable": T; + ' tag_class_ForkJoinObservable': T; constructor(private sources: Array | Promise>, private resultSelector?: (...values: Array) => T) { diff --git a/src/observable/FromEventObservable.ts b/src/observable/FromEventObservable.ts index c1b9c5fbad..2d01a35f17 100644 --- a/src/observable/FromEventObservable.ts +++ b/src/observable/FromEventObservable.ts @@ -38,7 +38,7 @@ export type EventTargetLike = EventTarget | NodeStyleEventEmmitter | JQueryStyle * */ export class FromEventObservable extends Observable { - " tag_class_FromEventObservable": [T, R]; + ' tag_class_FromEventObservable': [T, R]; /** * @param sourceObj diff --git a/src/observable/FromEventPatternObservable.ts b/src/observable/FromEventPatternObservable.ts index 2dcce76622..9e6ef70852 100644 --- a/src/observable/FromEventPatternObservable.ts +++ b/src/observable/FromEventPatternObservable.ts @@ -8,7 +8,7 @@ import {Subscriber} from '../Subscriber'; * */ export class FromEventPatternObservable extends Observable { - " tag_class_FromEventPatternObservable": [T, R]; + ' tag_class_FromEventPatternObservable': [T, R]; /** * @param addHandler diff --git a/src/observable/FromObservable.ts b/src/observable/FromObservable.ts index 1faa068103..31c599c5b7 100644 --- a/src/observable/FromObservable.ts +++ b/src/observable/FromObservable.ts @@ -19,7 +19,7 @@ const isArrayLike = ((x: any): x is ArrayLike => x && typeof x.length === * */ export class FromObservable extends Observable { - " tag_class_FromObservable": T; + ' tag_class_FromObservable': T; constructor(private ish: ObservableInput, private scheduler: Scheduler) { super(null); diff --git a/src/observable/IfObservable.ts b/src/observable/IfObservable.ts index c6c4de8938..3b92bffd84 100644 --- a/src/observable/IfObservable.ts +++ b/src/observable/IfObservable.ts @@ -3,7 +3,7 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class IfObservable extends Observable { - " tag_class_IfObservable": [T, R]; + ' tag_class_IfObservable': [T, R]; static create(condition: () => boolean, thenSource?: Observable, diff --git a/src/observable/IntervalObservable.ts b/src/observable/IntervalObservable.ts index 9931e73996..a94d4de62d 100644 --- a/src/observable/IntervalObservable.ts +++ b/src/observable/IntervalObservable.ts @@ -8,7 +8,7 @@ import {async} from '../scheduler/async'; * */ export class IntervalObservable extends Observable { - " tag_class_IntervalObservable": any; + ' tag_class_IntervalObservable': any; /** * @param period diff --git a/src/observable/IteratorObservable.ts b/src/observable/IteratorObservable.ts index 930a16ffe3..02b611a154 100644 --- a/src/observable/IteratorObservable.ts +++ b/src/observable/IteratorObservable.ts @@ -10,7 +10,7 @@ import {Subscription} from '../Subscription'; import {Subscriber} from '../Subscriber'; export class IteratorObservable extends Observable { - " tag_class_IteratorObservable": T; + ' tag_class_IteratorObservable': T; private iterator: any; diff --git a/src/observable/NeverObservable.ts b/src/observable/NeverObservable.ts index 1b50079bf0..f6a0e68360 100644 --- a/src/observable/NeverObservable.ts +++ b/src/observable/NeverObservable.ts @@ -6,7 +6,7 @@ import {noop} from '../util/noop'; * */ export class NeverObservable extends Observable { - " tag_class_NeverObservable": T; + ' tag_class_NeverObservable': T; /** * @return {NeverObservable} diff --git a/src/observable/PromiseObservable.ts b/src/observable/PromiseObservable.ts index d6ecb25444..8651e66349 100644 --- a/src/observable/PromiseObservable.ts +++ b/src/observable/PromiseObservable.ts @@ -8,7 +8,7 @@ import {Subscription} from '../Subscription'; * */ export class PromiseObservable extends Observable { - " tag_class_PromiseObservable": T; + ' tag_class_PromiseObservable': T; public value: T; diff --git a/src/observable/RangeObservable.ts b/src/observable/RangeObservable.ts index 434d95f3c0..a4554feaba 100644 --- a/src/observable/RangeObservable.ts +++ b/src/observable/RangeObservable.ts @@ -7,7 +7,7 @@ import {Subscriber} from '../Subscriber'; * */ export class RangeObservable extends Observable { - " tag_class_RangeObservable": any; + ' tag_class_RangeObservable': any; /** * @param start diff --git a/src/observable/ScalarObservable.ts b/src/observable/ScalarObservable.ts index 4c5d27c3ed..15ad40c67d 100644 --- a/src/observable/ScalarObservable.ts +++ b/src/observable/ScalarObservable.ts @@ -4,7 +4,7 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class ScalarObservable extends Observable { - " tag_class_ScalarObservable": T; + ' tag_class_ScalarObservable': T; static create(value: T, scheduler?: Scheduler): ScalarObservable { return new ScalarObservable(value, scheduler); diff --git a/src/observable/SubscribeOnObservable.ts b/src/observable/SubscribeOnObservable.ts index 31b30d36e4..ce4c5d8ca7 100644 --- a/src/observable/SubscribeOnObservable.ts +++ b/src/observable/SubscribeOnObservable.ts @@ -6,7 +6,7 @@ import {asap} from '../scheduler/asap'; import {isNumeric} from '../util/isNumeric'; export class SubscribeOnObservable extends Observable { - " tag_class_SubscribeOnObservable": T; + ' tag_class_SubscribeOnObservable': T; static create(source: Observable, delay: number = 0, scheduler: Scheduler = asap): Observable { return new SubscribeOnObservable(source, delay, scheduler); diff --git a/src/observable/TimerObservable.ts b/src/observable/TimerObservable.ts index e0cd07d8a9..ad725b2fac 100644 --- a/src/observable/TimerObservable.ts +++ b/src/observable/TimerObservable.ts @@ -11,7 +11,7 @@ import {Subscriber} from '../Subscriber'; * */ export class TimerObservable extends Observable { - " tag_class_TimerObservable": any; + ' tag_class_TimerObservable': any; /** * @param dueTime diff --git a/src/observable/UsingObservable.ts b/src/observable/UsingObservable.ts index f7f92e0f6d..cd1107ae71 100644 --- a/src/observable/UsingObservable.ts +++ b/src/observable/UsingObservable.ts @@ -3,7 +3,7 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class UsingObservable extends Observable { - " tag_class_UsingObservable": T; + ' tag_class_UsingObservable': T; static create(resourceFactory: () => Subscription, observableFactory: (resource: Subscription) => Observable): Observable { diff --git a/src/subject/AsyncSubject.ts b/src/subject/AsyncSubject.ts index 9884254401..9f47f83a76 100644 --- a/src/subject/AsyncSubject.ts +++ b/src/subject/AsyncSubject.ts @@ -3,7 +3,7 @@ import {Subscriber} from '../Subscriber'; import {Subscription} from '../Subscription'; export class AsyncSubject extends Subject { - " tag_class_AsyncSubject": T; + ' tag_class_AsyncSubject': T; value: T = null; hasNext: boolean = false; diff --git a/src/subject/BehaviorSubject.ts b/src/subject/BehaviorSubject.ts index 6e425049d7..1b0b0015a4 100644 --- a/src/subject/BehaviorSubject.ts +++ b/src/subject/BehaviorSubject.ts @@ -5,7 +5,7 @@ import {throwError} from '../util/throwError'; import {ObjectUnsubscribedError} from '../util/ObjectUnsubscribedError'; export class BehaviorSubject extends Subject { - " tag_class_BehaviorSubject": T; + ' tag_class_BehaviorSubject': T; constructor(private _value: T) { super(); diff --git a/src/subject/ReplaySubject.ts b/src/subject/ReplaySubject.ts index f4fae44a28..ce9837b78b 100644 --- a/src/subject/ReplaySubject.ts +++ b/src/subject/ReplaySubject.ts @@ -6,8 +6,8 @@ import {Subscription} from '../Subscription'; import {ObserveOnSubscriber} from '../operator/observeOn'; export class ReplaySubject extends Subject { - " tag_class_ReplaySubject": T; - + ' tag_class_ReplaySubject': T; + private events: ReplayEvent[] = []; private scheduler: Scheduler; private bufferSize: number;