(self, timeout=0.0)
| 2979 | return None |
| 2980 | |
| 2981 | def _sharded_message_generator(self, timeout=0.0): |
| 2982 | for _ in range(len(self.node_pubsub_mapping)): |
| 2983 | pubsub = next(self._pubsubs_generator) |
| 2984 | # Don't pass ignore_subscribe_messages here - let get_sharded_message |
| 2985 | # handle the filtering after processing subscription state changes |
| 2986 | message = pubsub.get_message( |
| 2987 | ignore_subscribe_messages=False, timeout=timeout |
| 2988 | ) |
| 2989 | if message is not None: |
| 2990 | return pubsub, message |
| 2991 | return None, None |
| 2992 | |
| 2993 | def _pubsubs_generator(self): |
| 2994 | while True: |
no test coverage detected