Comparing version 2.1.5 to 2.1.6
@@ -9,3 +9,2 @@ "use strict"; | ||
const isAsyncIterable_1 = require("../utils/isAsyncIterable"); | ||
const patchClientWritableStream_1 = require("../utils/patchClientWritableStream"); | ||
const readableToAsyncIterable_1 = require("../utils/readableToAsyncIterable"); | ||
@@ -31,3 +30,2 @@ const wrapClientError_1 = require("./wrapClientError"); | ||
const call = client.makeBidiStreamRequest(grpcMethodDefinition.path, grpcMethodDefinition.requestSerialize, grpcMethodDefinition.responseDeserialize, (0, convertMetadata_1.convertMetadataToGrpcJs)(metadata)); | ||
(0, patchClientWritableStream_1.patchClientWritableStream)(call); | ||
call.on('metadata', metadata => { | ||
@@ -34,0 +32,0 @@ onHeader?.((0, convertMetadata_1.convertMetadataFromGrpcJs)(metadata)); |
@@ -9,3 +9,2 @@ "use strict"; | ||
const isAsyncIterable_1 = require("../utils/isAsyncIterable"); | ||
const patchClientWritableStream_1 = require("../utils/patchClientWritableStream"); | ||
const wrapClientError_1 = require("./wrapClientError"); | ||
@@ -37,3 +36,2 @@ /** @internal */ | ||
}); | ||
(0, patchClientWritableStream_1.patchClientWritableStream)(call); | ||
call.on('metadata', metadata => { | ||
@@ -40,0 +38,0 @@ onHeader?.((0, convertMetadata_1.convertMetadataFromGrpcJs)(metadata)); |
{ | ||
"name": "nice-grpc", | ||
"version": "2.1.5", | ||
"version": "2.1.6", | ||
"description": "A Node.js gRPC library that is nice to you", | ||
@@ -37,7 +37,5 @@ "keywords": [ | ||
"@types/defer-promise": "^1.0.0", | ||
"@types/get-port": "^4.2.0", | ||
"@types/google-protobuf": "^3.7.4", | ||
"@types/node": "^14.18.23", | ||
"defer-promise": "^2.0.1", | ||
"get-port": "^5.1.1", | ||
"google-protobuf": "^3.14.0", | ||
@@ -49,7 +47,7 @@ "grpc-tools": "^1.10.0", | ||
"dependencies": { | ||
"@grpc/grpc-js": "^1.8.18", | ||
"@grpc/grpc-js": "^1.9.5", | ||
"abort-controller-x": "^0.4.0", | ||
"nice-grpc-common": "^2.0.2" | ||
}, | ||
"gitHead": "e25d70ac3d241c17781797bfd075f2ade2f28268" | ||
"gitHead": "dcb7b98bb34e99d16e276e806fdccad60e6072ab" | ||
} |
@@ -997,2 +997,11 @@ # nice-grpc [![npm version][npm-image]][npm-url] <!-- omit in toc --> | ||
Type augmentation to `Client` CallOptions is done automatically by adding a middleware, but can also be done by passing a generic. This code example shows how to correctly annotate client type given that middleware has type `ClientMiddleware<{callOption?: number}>`. | ||
```ts | ||
let client: ExampleServiceClient<{callOption?: number}>; | ||
client = createClientFactory() | ||
.use(middleware) | ||
.create(ExampleService, channel); | ||
``` | ||
##### Example: Logging | ||
@@ -999,0 +1008,0 @@ |
@@ -19,3 +19,2 @@ import {Client, ClientWritableStream} from '@grpc/grpc-js'; | ||
import {isAsyncIterable} from '../utils/isAsyncIterable'; | ||
import {patchClientWritableStream} from '../utils/patchClientWritableStream'; | ||
import {readableToAsyncIterable} from '../utils/readableToAsyncIterable'; | ||
@@ -65,4 +64,2 @@ import {BidiStreamingClientMethod} from './Client'; | ||
patchClientWritableStream(call); | ||
call.on('metadata', metadata => { | ||
@@ -69,0 +66,0 @@ onHeader?.(convertMetadataFromGrpcJs(metadata)); |
@@ -23,3 +23,2 @@ import {Client, ClientWritableStream} from '@grpc/grpc-js'; | ||
import {isAsyncIterable} from '../utils/isAsyncIterable'; | ||
import {patchClientWritableStream} from '../utils/patchClientWritableStream'; | ||
import {ClientStreamingClientMethod} from './Client'; | ||
@@ -80,4 +79,2 @@ import {wrapClientError} from './wrapClientError'; | ||
patchClientWritableStream(call); | ||
call.on('metadata', metadata => { | ||
@@ -84,0 +81,0 @@ onHeader?.(convertMetadataFromGrpcJs(metadata)); |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
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
9
1053
197781
103
3499
Updated@grpc/grpc-js@^1.9.5