style(lint): fix lint

ReactiveX · May 22, 2016 · 55d5141 · 55d5141
1 parent a5f50f3
commit 55d5141
Show file tree

Hide file tree

Showing 6 changed files with 17 additions and 25 deletions.
diff --git a/spec/subjects/ReplaySubject-spec.ts b/spec/subjects/ReplaySubject-spec.ts
@@ -225,7 +225,6 @@ describe('ReplaySubject', () => {
   it('should be an Observer which can be given to Observable.subscribe', () => {
     const source = Observable.of(1, 2, 3, 4, 5);
     const subject = new ReplaySubject(3);
-    const expected = [3, 4, 5];
     let results = [];
 
     subject.subscribe(x => results.push(x), null, () => results.push('done'));

diff --git a/src/ReplaySubject.ts b/src/ReplaySubject.ts
@@ -4,7 +4,7 @@ import {queue} from './scheduler/queue';
 import {Subscriber} from './Subscriber';
 import {Subscription} from './Subscription';
 import {ObserveOnSubscriber} from './operator/observeOn';
-import {SubjectSubscription} from './SubjectSubscription';
+
 /**
  * @class ReplaySubject<T>
  */

diff --git a/src/Subject.ts b/src/Subject.ts
@@ -52,34 +52,30 @@ export class Subject<T> extends Observable<T> implements ISubscription {
     if (this.isUnsubscribed) {
       throw new ObjectUnsubscribedError();
     }
-    if (!this.isStopped) {
-      this.hasError = true;
-      this.thrownError = err;
-      this.isStopped = true;
-      const { observers } = this;
-      const len = observers.length;
-      const copy = observers.slice();
-      for (let i = 0; i < len; i++) {
-        copy[i].error(err);
-      }
-      this.observers.length = 0;
+    this.hasError = true;
+    this.thrownError = err;
+    this.isStopped = true;
+    const { observers } = this;
+    const len = observers.length;
+    const copy = observers.slice();
+    for (let i = 0; i < len; i++) {
+      copy[i].error(err);
     }
+    this.observers.length = 0;
   }
 
   complete() {
     if (this.isUnsubscribed) {
       throw new ObjectUnsubscribedError();
     }
-    if (!this.isStopped) {
-      this.isStopped = true;
-      const { observers } = this;
-      const len = observers.length;
-      const copy = observers.slice();
-      for (let i = 0; i < len; i++) {
-        copy[i].complete();
-      }
-      this.observers.length = 0;
+    this.isStopped = true;
+    const { observers } = this;
+    const len = observers.length;
+    const copy = observers.slice();
+    for (let i = 0; i < len; i++) {
+      copy[i].complete();
     }
+    this.observers.length = 0;
   }
 
   unsubscribe() {

diff --git a/src/observable/dom/WebSocketSubject.ts b/src/observable/dom/WebSocketSubject.ts
@@ -96,7 +96,6 @@ export class WebSocketSubject<T> extends AnonymousSubject<T> {
         err => observer.error(err),
         () => observer.complete());
 
-
       return () => {
         const result = tryCatch(unsubMsg)();
         if (result === errorObject) {

diff --git a/src/operator/groupBy.ts b/src/operator/groupBy.ts
@@ -99,7 +99,6 @@ class GroupBySubscriber<T, K, R> extends Subscriber<T> implements RefCountSubscr
     }
 
     let group = groups.get(key);
-    let groupEmitted = false;
 
     let element: R;
     if (this.elementSelector) {

diff --git a/src/util/toSubscriber.ts b/src/util/toSubscriber.ts
@@ -18,7 +18,6 @@ export function toSubscriber<T>(
   return new Subscriber(nextOrObserver, error, complete);
 }
 
-
 export class SubjectSubscriber<T> extends Subscriber<T> {
   constructor(protected destination: Subject<T>) {
     super(destination);