def METHOD_NAME(self, client):
    for stream_name, callback in self._stream_callbacks.items():
        try:
            self.process_stream_updates(client, stream_name, callback)
            STREAMER_RESPONSES.labels(result='Success').inc()
        except grpc.RpcError as err:
            logging.error(
                "Error! Streaming from the cloud failed! [%s] %s",
                err.code(),
                err.details(),
                extra=EXCLUDE_FROM_ERROR_MONITORING if indicates_connection_error(err) else None,
            )
            STREAMER_RESPONSES.labels(result='RpcError').inc()
        except ValueError as err:
            logging.error("Error! Streaming from cloud failed! %s", err)
            STREAMER_RESPONSES.labels(result='ValueError').inc()