code: def test_poll_conn_for_notification(self):
      with self.conn.cursor() as cur:
          cur.execute("listen test")
          self.wait(cur)
  
      with self.sync_conn.cursor() as cur:
          cur.execute("notify test, 'hello'")
          self.sync_conn.commit()
  
      for i in range(10):
          self.conn.poll()
  
          if self.conn.notifies:
              n = self.conn.notifies.pop()
              self.assertEqual(n.channel, "test")
              self.assertEqual(n.payload, "hello")
              break
          time.sleep(0.1)
      else:
          self.fail("No notification received")
  
imports: import gc
  import time
  import unittest
  import warnings
  import psycopg2
  import psycopg2.errors
  from psycopg2 import extensions
  from .testutils import ConnectingTestCase, StringIO, skip_before_postgres, skip_if_crdb, crdb_version, slow
label_desc: Use image node_id 33 for calling the AsyncTests obj's underlying member method code with example usage: obj.test_poll_conn_for_notification() without return types