From aa8d1a0638db1ff5b6a40f680d7e3f662dd663ce Mon Sep 17 00:00:00 2001
From: Perreal Guillaume <guillaume.perreal@irstea.fr>
Date: Wed, 9 Oct 2019 14:15:38 +0200
Subject: [PATCH] Added the consoleObserver;
---
src/rxjs/console.observer.ts | 13 +++++++++++++
src/rxjs/index.ts | 1 +
2 files changed, 14 insertions(+)
create mode 100644 src/rxjs/console.observer.ts
diff --git a/src/rxjs/console.observer.ts b/src/rxjs/console.observer.ts
new file mode 100644
index 0000000..60b2997
--- /dev/null
+++ b/src/rxjs/console.observer.ts
@@ -0,0 +1,13 @@
+import { Observer } from 'rxjs';
+
+let serial = 0;
+
+// tslint:disable:no-console
+export function consoleObserver<T>(subject = `spy#${++serial}`): Observer<T> {
+ return <Observer<T>>{
+ closed: false,
+ next: value => console.log(subject, 'next:', value),
+ error: err => console.log(subject, 'error:', err),
+ complete: () => console.log(subject, 'completed.'),
+ };
+}
diff --git a/src/rxjs/index.ts b/src/rxjs/index.ts
index 881006d..fc98e41 100644
--- a/src/rxjs/index.ts
+++ b/src/rxjs/index.ts
@@ -3,3 +3,4 @@ export { safeCombineLatest } from './safe-combine-latest.observable';
export { safeForkJoin } from './safe-fork-join.observable';
export { select } from './select.operator';
export { untilDestroyed } from './until-destroyed.operator';
+export { consoleObserver } from './console.observer';
--
GitLab