def process_connection_lost()

in pyignite/connection/aio_connection.py [0:0]

• 11 lines of code
• 7 McCabe index (conditional complexity)

    def process_connection_lost(self, err, reconnect=False):
        self.failed = True
        for _, fut in self._pending_reqs.items():
            if not fut.done():
                fut.set_exception(err)
        self._pending_reqs.clear()

        if self._transport_closed_fut and not self._transport_closed_fut.done():
            self._transport_closed_fut.set_result(None)

        if reconnect and not self._closed:
            self._on_connection_lost(err)
            self._loop.create_task(self._reconnect())