code: def begin_stream_loop(stream, poll_interval):
      
      while should_continue():
          try:
              stream.start_polling(poll_interval)
          except Exception as e:
              # Infinite restart
              logger.error("Exception while polling. Restarting in 1 second.", exc_info=True)
              time.sleep(1)
docs: Start and maintain the streaming connection...