Comparing version 1.6.5 to 1.6.7
@@ -80,10 +80,11 @@ "use strict"; | ||
GrpcProtocol.prototype.onMessage = function (streamID, message) { | ||
if (!message) { | ||
return; | ||
} | ||
var stream = this.streams.get(streamID); | ||
if (stream) { | ||
if (message) { | ||
stream.messages.put(message); | ||
} | ||
stream.messages.put(message); | ||
} | ||
else { | ||
console.warn(" stream not found for message:", streamID); | ||
console.warn("stream not found for message:", streamID); | ||
} | ||
@@ -90,0 +91,0 @@ }; |
{ | ||
"name": "wsgrpc", | ||
"version": "1.6.5", | ||
"version": "1.6.7", | ||
"description": "Using WebSocket as gRPC transport", | ||
@@ -5,0 +5,0 @@ "author": "tsangpo", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
283357
7040