Revert "fix(find): force unsubscribe when it completes or errors (#2550…

…)" (#2607) This reverts commit df78c4c.
ReactiveX · Jun 14, 2017 · ca50240 · ca50240
1 parent 380fbcf
commit ca50240
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 46 deletions.
diff --git a/spec/helpers/doNotUnsubscribe.ts b/spec/helpers/doNotUnsubscribe.ts
diff --git a/spec/operators/find-spec.ts b/spec/operators/find-spec.ts
@@ -1,7 +1,6 @@
 import {expect} from 'chai';
 import * as Rx from '../../dist/cjs/Rx';
 import marbleTestingSignature = require('../helpers/marble-testing'); // tslint:disable-line:no-require-imports
-import { doNotUnsubscribe } from '../helpers/doNotUnsubscribe';
 
 declare const { asDiagram };
 declare const hot: typeof marbleTestingSignature.hot;
@@ -163,33 +162,6 @@ describe('Observable.prototype.find', () => {
     expectSubscriptions(source.subscriptions).toBe(subs);
   });
 
-  it('should unsubscribe from source when complete, even if following operator does not unsubscribe', () => {
-    const values = {a: 3, b: 9, c: 15, d: 20};
-    const source = hot('---a--b--c--d---|', values);
-    const subs =       '^        !       ';
-    const expected =   '---------(c|)    ';
-
-    const predicate = function (x) { return x % 5 === 0; };
-
-    expectObservable((<any>source).find(predicate).let(doNotUnsubscribe)).toBe(expected, values);
-    expectSubscriptions(source.subscriptions).toBe(subs);
-  });
-
-  it('should unsubscribe from source when predicate function errors,' +
-    ' even if followring operator does not unsubscribe', () => {
-
-    const source = hot('--a--b--c--|');
-    const subs =       '^ !';
-    const expected =   '--#';
-
-    const predicate = function (value) {
-      throw 'error';
-    };
-
-    expectObservable((<any>source).find(predicate).let(doNotUnsubscribe)).toBe(expected);
-    expectSubscriptions(source.subscriptions).toBe(subs);
-  });
-
   it('should support type guards without breaking previous behavior', () => {
     // tslint:disable no-unused-variable
 

diff --git a/src/operator/find.ts b/src/operator/find.ts
@@ -85,7 +85,6 @@ export class FindValueSubscriber<T> extends Subscriber<T> {
 
     destination.next(value);
     destination.complete();
-    this.unsubscribe();
   }
 
   protected _next(value: T): void {
@@ -98,7 +97,6 @@ export class FindValueSubscriber<T> extends Subscriber<T> {
       }
     } catch (err) {
       this.destination.error(err);
-      this.unsubscribe();
     }
   }