@zum/flash-client
Advanced tools
Comparing version 0.0.30 to 0.0.31
@@ -25,3 +25,3 @@ "use strict"; | ||
const routeIssuesObservableArray = entityIds.map((entityId) => { | ||
return routeIssuesObservableSubject.pipe((0, operators_1.filter)((event) => event.entityId === entityId), (0, operators_1.switchMap)((event) => { | ||
return routeIssuesObservableSubject.pipe((0, operators_1.filter)((event) => event.entityId === entityId), (0, operators_1.mergeMap)((event) => { | ||
if ((0, utils_1.isNull)(event.data)) { | ||
@@ -28,0 +28,0 @@ const { districtId, batchId } = (0, exports.decodeRouteIssueEntityId)(event.entityId); |
import { merge, Observable, Subject } from 'rxjs'; | ||
import { filter, map, switchMap } from 'rxjs/operators'; | ||
import { filter, map, mergeMap } from 'rxjs/operators'; | ||
import { UnreachableCaseError } from 'ts-essentials'; | ||
@@ -39,3 +39,3 @@ import { FlashEvent } from '../../connect/types'; | ||
filter((event) => event.entityId === entityId), | ||
switchMap((event: FlashEvent) => { | ||
mergeMap((event: FlashEvent) => { | ||
if (isNull(event.data)) { | ||
@@ -42,0 +42,0 @@ const { districtId, batchId } = decodeRouteIssueEntityId(event.entityId); |
{ | ||
"name": "@zum/flash-client", | ||
"version": "0.0.30", | ||
"version": "0.0.31", | ||
"description": "Client for connecting to Zum Flash server", | ||
@@ -5,0 +5,0 @@ "license": "UNLICENSED", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
154433