def receive(self):
        self._flush_buffer()
        message = ""
        start = time.time()

        while len(message) == 0 or message.count("}") < message.count("{"):
            message = self.buffer
            duration = time.time() - start
            if duration > self._request_timeout:
                raise OVSDBClient.ReceiveTimeoutError(duration, message)

        return json.loads(message)
dataset/ETHPy150Open relaxdiego/ovs-lab/shared/lesson03/ovsdb_client.py/OVSDBClient.receive/original