INNER CODE UNIT · Python

cleanup

permitio/fastapi_websocket_pubsub · fastapi_websocket_pubsub/event_broadcaster.py:297

                            def cleanup(task):
                                self._tasks.remove(task)

                            task.add_done_callback(cleanup)
                    except:
                        logger.exception("Failed handling incoming broadcast")
                logger.info(
                    "No more events to read from subscriber (underlying connection closed)"
                )
        finally:
            if self.listening_broadcast_channel is not None:
                await self.listening_broadcast_channel.disconnect()
                self.listening_broadcast_channel = None

View source record →