|
@@ -20,11 +20,11 @@ const payload: Observable<BaseMessage> = streamService.stream().pipe(
|
|
|
);
|
|
|
|
|
|
|
|
|
-payload.pipe(take(3)).subscribe({
|
|
|
- next: data => console.log(data),
|
|
|
- error: err => console.error(err),
|
|
|
- complete: () => console.log(`Streaming Completed`)
|
|
|
-})
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
|
|
|
let storage: LogSetting = {
|