def begin_stream_loop(stream, poll_interval):
while should_continue():<EOL><INDENT>try:<EOL><INDENT>stream.start_polling(poll_interval)<EOL><DEDENT>except Exception as e:<EOL><INDENT>logger.error("<STR_LIT>", exc_info=True)<EOL>time.sleep(<NUM_LIT:1>)<EOL><DEDENT><DEDENT>
Start and maintain the streaming connection...