def run(self):
if not self._queue:<EOL><INDENT>raise Exception("<STR_LIT>")<EOL><DEDENT>factory = LiveStreamFactory(self)<EOL>self._reactor.connectSSL("<STR_LIT>", <NUM_LIT>, factory, ssl.ClientContextFactory())<EOL>self._reactor.run()<EOL>
Called by the process, it runs it.

        NEVER call this method directly. Instead call start() to start the separate process.
        If you don't want to use a second process, then call fetch() directly on this istance.

        To stop, call terminate()