fix graphql send cancel on break from subscription loop

Author: jell-o-fishi

rsocket/graphql/rsocket_transport.py

@@ -121,17 +121,17 @@ def request(self, n: int):
         self._rsocket_client.request_stream(rsocket_payload).subscribe(subscriber)
 
         while True:
-            response = await received_queue.get()
+            try:
+                response = await received_queue.get()
 
-            if isinstance(response, Exception):
-                raise response
+                if isinstance(response, Exception):
+                    raise response
 
-            if response is complete_object:
-                break
+                if response is complete_object:
+                    break
 
-            execution_result = self._response_to_execution_result(response)
+                execution_result = self._response_to_execution_result(response)
 
-            try:
                 yield execution_result
             except GeneratorExit:
                 logger().debug('Generator exited')