code: def _on_response(self, response):
          
  
          _LOGGER.debug(
              "Scheduling callbacks for %s messages.", len(response.received_messages)
          )
  
          # Immediately modack the messages we received, as this tells the server
          # that we've received them.
          items = [
              requests.ModAckRequest(message.ack_id, self._ack_histogram.percentile(99))
              for message in response.received_messages
          ]
          self._dispatcher.modify_ack_deadline(items)
          for received_message in response.received_messages:
              message = google.cloud.pubsub_v1.subscriber.message.Message(
                  received_message.message, received_message.ack_id, self._scheduler.queue
              )
              # TODO: Immediately lease instead of using the callback queue.
              self._scheduler.schedule(self._callback, message)
docs: Process all received Pub/Sub messages.
  
          For each message, send a modified acknowledgment request to the
          server. This prevents expiration of the message due to buffering by
          gRPC or proxy/firewall. This makes the server and client expiration
          timer closer to each other thus preventing the message being
          redelivered multiple times.
  
          After the messages have all had their ack deadline updated, execute
          the callback for each message using the executor.