code: def _generate_dicts(self, count):
      return [
          ReceivedMessage.to_dict(m)
          for m in self._generate_messages(count)
      ]
  
imports: from __future__ import annotations
  from typing import Any
  from unittest import mock
  from google.api_core.gapic_v1.method import DEFAULT
  from google.cloud.pubsub_v1.types import ReceivedMessage
  from airflow.providers.google.cloud.operators.pubsub import PubSubCreateSubscriptionOperator, PubSubCreateTopicOperator, PubSubDeleteSubscriptionOperator, PubSubDeleteTopicOperator, PubSubPublishMessageOperator, PubSubPullOperator
label_desc: Use image node_id 2 for calling the TestPubSubPullOperator obj's underlying member method code with example usage: obj._generate_dicts(count) and returns: unknown