piwebasync/websockets/client.py
async def _transfer_data(self, protocol: WebsocketAuthProtocol) -> None:
        """
        Receive and process messages from websocket connection. Place processed
        messages in buffer

        This method will continuously receive messages from an open websocket
        connection. It is always awaited on by the `run` method. Any that ocurrs
        will propagate to and be handled by the parent task. Flow control is
        handled at the protocol level
        """

        try:
            self._no_data_transfer_event.clear()
            async for message in protocol:
                websocket_message = self._process_message(message)
                logger.debug("message received for endpoint %s", websocket_message.url)
                self._buffer.append(websocket_message)
                # wake up receiver if waiting for a message
                if self._pop_message_waiter is not None:
                    logger.debug("waking receiver")
                    self._pop_message_waiter.set_result(None)
                    self._pop_message_waiter = None
        finally:
            self._no_data_transfer_event.set()

        Receive and process messages from websocket connection. Place processed
        messages in buffer

        This method will continuously receive messages from an open websocket
        connection. It is always awaited on by the `run` method. Any that ocurrs
        will propagate to and be handled by the parent task. Flow control is
        handled at the protocol level
        
Receive and process messages from websocket connection. Place processed
messages in buffer

This method will continuously receive messages from an open websocket
connection. It is always awaited on by the `run` method. Any that ocurrs
will propagate to and be handled by the parent task. Flow control is
handled at the protocol level
Receive and process messages from websocket connection . Place processed messages in buffer This method will continuously receive messages from an open websocket connection . It is always awaited on by the ` run ` method . Any that ocurrs will propagate to and be handled by the parent task . Flow control is handled at the protocol level
async def _transfer_data(self, protocol: WebsocketAuthProtocol) -> None:
        try:
            self._no_data_transfer_event.clear()
            async for message in protocol:
                websocket_message = self._process_message(message)
                logger.debug("message received for endpoint %s", websocket_message.url)
                self._buffer.append(websocket_message)
                if self._pop_message_waiter is not None:
                    logger.debug("waking receiver")
                    self._pop_message_waiter.set_result(None)
                    self._pop_message_waiter = None
        finally:
            self._no_data_transfer_event.set()
async def _transfer_data ( self , protocol : WebsocketAuthProtocol ) -> None : try : self . _no_data_transfer_event . clear ( ) async for message in protocol : websocket_message = self . _process_message ( message ) logger . debug ( "message received for endpoint %s" , websocket_message . url ) self . _buffer . append ( websocket_message ) if self . _pop_message_waiter is not None : logger . debug ( "waking receiver" ) self . _pop_message_waiter . set_result ( None ) self . _pop_message_waiter = None finally : self . _no_data_transfer_event . set ( )
Receive and process messages from websocket connection.
Receive and process messages from websocket connection .
"""
        Receive and process messages from websocket connection. Place processed
        messages in buffer

        This method will continuously receive messages from an open websocket
        connection. It is always awaited on by the `run` method. Any that ocurrs
        will propagate to and be handled by the parent task. Flow control is
        handled at the protocol level
        """ # wake up receiver if waiting for a message
self
protocol
WebsocketAuthProtocol