(self, topic: str)
| 50 | return self.pubsub[topic] |
| 51 | |
| 52 | def remove_topic(self, topic: str): |
| 53 | logger.info(f"REMOVING TOPIC: {topic}") |
| 54 | if topic not in self.pubsub: |
| 55 | raise ValueError(f"Topic {topic} not found") |
| 56 | del self.pubsub[topic] |
nothing calls this directly
no outgoing calls
no test coverage detected