diff --git a/packages/grpc-js/src/call-stream.ts b/packages/grpc-js/src/call-stream.ts index ca3049e7..11f9adc0 100644 --- a/packages/grpc-js/src/call-stream.ts +++ b/packages/grpc-js/src/call-stream.ts @@ -227,7 +227,7 @@ export class Http2CallStream implements Call { const filteredStatus = this.filterStack.receiveTrailers( this.finalStatus! ); - this.listener!.onReceiveStatus(filteredStatus); + this.listener?.onReceiveStatus(filteredStatus); if (this.subchannel) { this.subchannel.callUnref(); this.subchannel.removeDisconnectListener(this.disconnectListener); @@ -289,7 +289,7 @@ export class Http2CallStream implements Call { ); this.canPush = false; process.nextTick(() => { - this.listener!.onReceiveMessage(message); + this.listener?.onReceiveMessage(message); this.maybeOutputStatus(); }); } @@ -465,7 +465,7 @@ export class Http2CallStream implements Call { } try { const finalMetadata = this.filterStack.receiveMetadata(metadata); - this.listener!.onReceiveMetadata(finalMetadata); + this.listener?.onReceiveMetadata(finalMetadata); } catch (error) { this.endCall({ code: Status.UNKNOWN,