diff --git a/confluent_client/confluent/client.py b/confluent_client/confluent/client.py index f3c91225..07a85423 100644 --- a/confluent_client/confluent/client.py +++ b/confluent_client/confluent/client.py @@ -234,7 +234,6 @@ def send_request(operation, path, server, parameters=None): # their unused data result = tlvdata.recv(server) while '_requestdone' not in result: - yield result result = tlvdata.recv(server) inflight = True payload = {'operation': operation, 'path': path}