alpaca_trade_api/stream2.py
def run(self, initial_channels=[]):
        '''Run forever and block until exception is rasised.
        initial_channels is the channels to start with.
        '''
        loop = asyncio.get_event_loop()
        try:
            loop.run_until_complete(self.subscribe(initial_channels))
            loop.run_forever()
        finally:
            loop.run_until_complete(self.close())
def run(self, initial_channels=[]):
        '''Run forever and block until exception is rasised.
        initial_channels is the channels to start with.
        '''
        loop = asyncio.get_event_loop()
        try:
            loop.run_until_complete(self.subscribe(initial_channels))
            loop.run_forever()
        finally:
            loop.run_until_complete(self.close())
def run ( self , initial_channels = [ ] ) : loop = asyncio . get_event_loop ( ) try : loop . run_until_complete ( self . subscribe ( initial_channels ) ) loop . run_forever ( ) finally : loop . run_until_complete ( self . close ( ) )
Run forever and block until exception is rasised.
        initial_channels is the channels to start with.
Run forever and block until exception is rasised . initial_channels is the channels to start with .