async def METHOD_NAME(self):
    if self.verbose:
        self.log(iso8601(milliseconds()), 'receive loop')
    while not self.closed():
        try:
            message = await self.receive()
            # self.log(iso8601(milliseconds()), 'received', message)
            self.handle_message(message)
        except Exception as e:
            error = NetworkError(str(e))
            if self.verbose:
                self.log(iso8601(milliseconds()), 'receive_loop', 'Exception', error)
            self.reset(error)