grpc-js: Don't initiate a read after receiving a message

This commit is contained in:
Michael Lumish 2020-06-16 13:36:20 -07:00
parent 1d14203c38
commit ece7d0f56d
1 changed files with 2 additions and 6 deletions

View File

@ -558,9 +558,7 @@ export class Client {
}, },
// eslint-disable-next-line @typescript-eslint/no-explicit-any // eslint-disable-next-line @typescript-eslint/no-explicit-any
onReceiveMessage(message: any) { onReceiveMessage(message: any) {
if (stream.push(message)) { stream.push(message);
call.startRead();
}
}, },
onReceiveStatus(status: StatusObject) { onReceiveStatus(status: StatusObject) {
if (receivedStatus) { if (receivedStatus) {
@ -656,9 +654,7 @@ export class Client {
stream.emit('metadata', metadata); stream.emit('metadata', metadata);
}, },
onReceiveMessage(message: Buffer) { onReceiveMessage(message: Buffer) {
if (stream.push(message)) { stream.push(message)
call.startRead();
}
}, },
onReceiveStatus(status: StatusObject) { onReceiveStatus(status: StatusObject) {
if (receivedStatus) { if (receivedStatus) {