def run(self, initial_channels=[]):
loop = asyncio.get_event_loop()<EOL>try:<EOL><INDENT>loop.run_until_complete(self.subscribe(initial_channels))<EOL>loop.run_forever()<EOL><DEDENT>finally:<EOL><INDENT>loop.run_until_complete(self.close())<EOL><DEDENT>
Run forever and block until exception is rasised.
        initial_channels is the channels to start with.