alpaca_trade_api/stream2.py
async def subscribe(self, channels):
        '''Start subscribing channels.
        If the necessary connection isn't open yet, it opens now.
        '''
        ws_channels = []
        nats_channels = []
        for c in channels:
            if c.startswith(('Q.', 'T.', 'A.', 'AM.',)):
                nats_channels.append(c)
            else:
                ws_channels.append(c)

        if len(ws_channels) > 0:
            await self._ensure_ws()
            await self._ws.send(json.dumps({
                'action': 'listen',
                'data': {
                    'streams': ws_channels,
                }
            }))

        if len(nats_channels) > 0:
            await self._ensure_nats()
            await self.polygon.subscribe(nats_channels)
async def subscribe(self, channels):
        '''Start subscribing channels.
        If the necessary connection isn't open yet, it opens now.
        '''
        ws_channels = []
        nats_channels = []
        for c in channels:
            if c.startswith(('Q.', 'T.', 'A.', 'AM.',)):
                nats_channels.append(c)
            else:
                ws_channels.append(c)

        if len(ws_channels) > 0:
            await self._ensure_ws()
            await self._ws.send(json.dumps({
                'action': 'listen',
                'data': {
                    'streams': ws_channels,
                }
            }))

        if len(nats_channels) > 0:
            await self._ensure_nats()
            await self.polygon.subscribe(nats_channels)
async def subscribe ( self , channels ) : ws_channels = [ ] nats_channels = [ ] for c in channels : if c . startswith ( ( 'Q.' , 'T.' , 'A.' , 'AM.' , ) ) : nats_channels . append ( c ) else : ws_channels . append ( c ) if len ( ws_channels ) > 0 : await self . _ensure_ws ( ) await self . _ws . send ( json . dumps ( { 'action' : 'listen' , 'data' : { 'streams' : ws_channels , } } ) ) if len ( nats_channels ) > 0 : await self . _ensure_nats ( ) await self . polygon . subscribe ( nats_channels )
Start subscribing channels.
        If the necessary connection isn't open yet, it opens now.
Start subscribing channels . If the necessary connection isn t open yet it opens now .