Method recv

binance/ws/depthcache.py:191–201

(self)

        await self._socket.__aexit__(*args, **kwargs)

    async def recv(self):
        dc = None
        while not dc:
            try:
                res = await asyncio.wait_for(self._socket.recv(), timeout=self.TIMEOUT)
                self._log.debug(f"Received message: {res}")
            except Exception as e:
                self._log.warning(f"Exception recieving message: {e.__class__.__name__} (e) ")
            else:
                dc = await self._depth_event(res)
        return dc

    async def _init_cache(self):
        """Initialise the depth cache calling REST endpoint