grpc-server-js
Advanced tools
Comparing version 0.3.1 to 0.3.2
@@ -73,2 +73,8 @@ 'use strict'; | ||
async _write (chunk, encoding, callback) { | ||
// This function is asynchronous in order to support async compression. | ||
// The following code does not work with `write()` being asynchronous, but | ||
// such code should be utilizing the `write()` callback. | ||
// stream.write(data); | ||
// stream.write(data); | ||
// stream.emit('error', err); | ||
try { | ||
@@ -82,3 +88,3 @@ const response = await this[kCall].serializeMessage(chunk); | ||
callback(); | ||
callback(null); | ||
} catch (err) { | ||
@@ -85,0 +91,0 @@ err.code = Status.INTERNAL; |
@@ -177,7 +177,3 @@ 'use strict'; | ||
} else if (values !== undefined) { | ||
if (isCustomMetadata(key)) { | ||
values.split(',').forEach((v) => { result.add(key, v.trim()); }); | ||
} else { | ||
result.add(key, values); | ||
} | ||
result.add(key, values); | ||
} | ||
@@ -184,0 +180,0 @@ } |
@@ -209,3 +209,10 @@ 'use strict'; | ||
this[kHandlers].set(name, { func: handler, serialize, deserialize, type }); | ||
this[kHandlers].set(name, { | ||
func: handler, | ||
serialize, | ||
deserialize, | ||
type, | ||
path: name | ||
}); | ||
return true; | ||
@@ -212,0 +219,0 @@ } |
{ | ||
"name": "grpc-server-js", | ||
"version": "0.3.1", | ||
"version": "0.3.2", | ||
"description": "Pure JavaScript gRPC Server", | ||
@@ -28,3 +28,3 @@ "author": "Colin J. Ihrig <cjihrig@gmail.com> (http://www.cjihrig.com/)", | ||
"@grpc/proto-loader": "0.5.x", | ||
"belly-button": "6.x.x", | ||
"belly-button": "7.x.x", | ||
"cb-barrier": "1.x.x", | ||
@@ -31,0 +31,0 @@ "@hapi/lab": "22.x.x" |
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
58611
1638