Revert "refactor: use isObservable provided by rxjs 6.1+ (#27668)"

This reverts commit 92c547830a.
This commit is contained in:
Miško Hevery
2019-11-27 13:00:59 -08:00
parent c5006e025f
commit 85b551a388
13 changed files with 50 additions and 22 deletions

View File

@ -17,7 +17,6 @@ ts_library(
"//packages/core/testing",
"//packages/platform-browser",
"//packages/private/testing",
"@npm//rxjs",
],
)

View File

@ -6,7 +6,6 @@
* found in the LICENSE file at https://angular.io/license
*/
import {Observable} from 'rxjs';
import {AfterContentChecked, AfterContentInit, AfterViewChecked, AfterViewInit, ChangeDetectorRef, DoCheck, ElementRef, ErrorHandler, EventEmitter, Injector, OnChanges, OnDestroy, OnInit, Renderer2, SimpleChange, TemplateRef, ViewContainerRef,} from '@angular/core';
import {getDebugContext} from '@angular/core/src/errors';
import {ArgumentType, DepFlags, NodeFlags, Services, anchorDef, asElementData, directiveDef, elementDef, providerDef, textDef} from '@angular/core/src/view/index';
@ -342,11 +341,13 @@ import {ARG_TYPE_VALUES, checkNodeInlineOrDynamic, createRootView, createAndGetR
let unsubscribeSpy: any;
class SomeService {
emitter = new Observable((callback: any) => {
const subscription = emitter.subscribe(callback);
unsubscribeSpy = spyOn(subscription, 'unsubscribe').and.callThrough();
return subscription;
});
emitter = {
subscribe: (callback: any) => {
const subscription = emitter.subscribe(callback);
unsubscribeSpy = spyOn(subscription, 'unsubscribe').and.callThrough();
return subscription;
}
};
}
const handleEvent = jasmine.createSpy('handleEvent');