Collect done coroutine results (or exceptions) in websocket

Author: Marco Paolini

pushpull/amqp/rpc/driver_aioamqp.py

@@ -35,7 +35,7 @@ async def __aenter__(self):
                 routing_key=app_routing_key
             )
             send_exchange_name, send_routing_key, reply_to = '', None, None
-        logger.debug('connected ok')
+        logger.info('connected with role {} to ok'.format(self.role))
         return (
             Sender(self._chan, send_exchange_name, send_routing_key, reply_to=reply_to),
             Receiver(self._chan, receive_queue_name)

pushpull/websocket/gateway.py

@@ -49,7 +49,11 @@ async def websocket_rabbitmq_gateway(request):
             )
             logger.info('exiting due to done coroutines %r', done)
             for coro in pending:
+                logger.warning('cancelling pending coroutine %r', coro)
                 coro.cancel()
+            for coro in done:
+                result = coro.result()
+                logger.info('coroutine %r done, result: %r', coro, result)
     except Exception:
         logger.exception('exception while handling request')
     finally: