@nestjs/platform-ws
Advanced tools
Comparing version 9.3.9 to 9.3.10
@@ -7,2 +7,3 @@ "use strict"; | ||
const load_package_util_1 = require("@nestjs/common/utils/load-package.util"); | ||
const shared_utils_1 = require("@nestjs/common/utils/shared.utils"); | ||
const websockets_1 = require("@nestjs/websockets"); | ||
@@ -64,3 +65,3 @@ const constants_1 = require("@nestjs/websockets/constants"); | ||
const close$ = (0, rxjs_1.fromEvent)(client, constants_1.CLOSE_EVENT).pipe((0, operators_1.share)(), (0, operators_1.first)()); | ||
const source$ = (0, rxjs_1.fromEvent)(client, 'message').pipe((0, operators_1.mergeMap)(data => this.bindMessageHandler(data, handlers, transform).pipe((0, operators_1.filter)(result => result))), (0, operators_1.takeUntil)(close$)); | ||
const source$ = (0, rxjs_1.fromEvent)(client, 'message').pipe((0, operators_1.mergeMap)(data => this.bindMessageHandler(data, handlers, transform).pipe((0, operators_1.filter)(result => !(0, shared_utils_1.isNil)(result)))), (0, operators_1.takeUntil)(close$)); | ||
const onMessage = (response) => { | ||
@@ -67,0 +68,0 @@ if (client.readyState !== READY_STATE.OPEN_STATE) { |
{ | ||
"name": "@nestjs/platform-ws", | ||
"version": "9.3.9", | ||
"version": "9.3.10", | ||
"description": "Nest - modern, fast, powerful node.js web framework (@platform-ws)", | ||
@@ -21,3 +21,3 @@ "author": "Kamil Mysliwiec", | ||
"tslib": "2.5.0", | ||
"ws": "8.12.1" | ||
"ws": "8.13.0" | ||
}, | ||
@@ -24,0 +24,0 @@ "peerDependencies": { |
27758
199