(self, topic: str)
| 44 | return self.pubsub[topic] |
| 45 | |
| 46 | def get_topic(self, topic: str): |
| 47 | logger.info(f"GETTING TOPIC: {topic}") |
| 48 | if topic not in self.pubsub: |
| 49 | raise ValueError(f"Topic {topic} not found") |
| 50 | return self.pubsub[topic] |
| 51 | |
| 52 | def remove_topic(self, topic: str): |
| 53 | logger.info(f"REMOVING TOPIC: {topic}") |