def receive(self):
        response = self.ws.receive()
        try:
            response = json.loads(response)
        except:
            log.debug("Response couldn't be decoded: {}".format(repr(response)))
            raise
        log.debug("Received response : {response}".format(response=response))
        if response.get('type') == 'response':
            if response.get('command_id') == self['command_id']:
                return Response(self.ws, response)
            else:
                raise AssertionError("Unexpected response id in : {stuff}".format(stuff=response))
        else:
            raise AssertionError("Was expecting a response, instead got {stuff}".format(stuff=response))
Await for further response from our peer
dataset/ETHPy150Open datastax/cstar_perf/frontend/cstar_perf/frontend/lib/socket_comms.py/CommandResponseBase.receive