def test_send_sync_rpc_response(self):
    expected = SyncRPCResponse(reqId=123, respBody=self._expected_resp)
    self._sync_rpc_client._response_queue.put(expected)
    res = self._sync_rpc_client.send_sync_rpc_response()
    actual = next(res)
    self.assertEqual(expected, actual)
    expected = SyncRPCResponse(heartBeat=True)
    actual = next(res)
    self.assertEqual(expected, actual)
def test_send_sync_rpc_response(self):
    expected = SyncRPCResponse(reqId=123, respBody=self._expected_resp)
    self._sync_rpc_client._response_queue.put(expected)
    res = self._sync_rpc_client.send_sync_rpc_response()
    actual = next(res)
    self.assertEqual(expected, actual)
    expected = SyncRPCResponse(heartBeat=True)
    actual = next(res)
    self.assertEqual(expected, actual)