A code sample from the article https://joshwulf.com/blog/2020/03/camunda-cloud-connection-2/

Middleware-signals-use.ts

private handleGrpcError = (stream: any) => async (err: any) => {
  // this.emit('error', err)
  this.emit(MiddlewareSignals.Event.Error, err)
  // this.logger.error(`GRPC ERROR: ${err.message}`)
  this.emit(MiddlewareSignals.Log.Error, `GRPC ERROR: ${err.message}`)
  const channelState = await this.watchGrpcChannel()
  // this.logger.debug(
  // 	`gRPC Channel state: ${connectivityState[channelState]}`
  // )
  this.emit(
    MiddlewareSignals.Log.Debug,
    `gRPC Channel state: ${connectivityState[channelState]}`
  )
  stream.removeAllListeners()
  if (
    channelState === GrpcState.READY ||
    channelState === GrpcState.IDLE
  ) {
    // this.logger.info('gRPC Channel reconnected')
    this.emit(MiddlewareSignals.Log.Info, 'gRPC Channel reconnected')
    // this.emit('ready')
    this.emit(MiddlewareSignals.Event.Ready)
  }
}