Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
Object.keys(observables).forEach((name) => {
if(observables[name] instanceof Rx.Observable) {
providedArgs[name] = observables[name];
} else {
providedArgs[name] = createObservable(
Rx.ReactiveTest.onNext(11, observables[name])
);
}
});
.define('onNext', (...args) => Rx.ReactiveTest.onNext(...args))
.define('onCompleted', (...args) => Rx.ReactiveTest.onCompleted(...args))
injector.define('onNext', (...args) => Rx.ReactiveTest.onNext(...args));