Method
__init__
(
self,
pubsub,
sleep_time: float,
daemon: bool = False,
exception_handler: Union[
Callable[[Exception, "PubSub", "PubSubWorkerThread"], None], None
] = None,
sharded_pubsub: bool = False,
)
Source from the content-addressed store, hash-verified
| 1615 | |
| 1616 | class PubSubWorkerThread(threading.Thread): |
| 1617 | def __init__( |
| 1618 | self, |
| 1619 | pubsub, |
| 1620 | sleep_time: float, |
| 1621 | daemon: bool = False, |
| 1622 | exception_handler: Union[ |
| 1623 | Callable[[Exception, "PubSub", "PubSubWorkerThread"], None], None |
| 1624 | ] = None, |
| 1625 | sharded_pubsub: bool = False, |
| 1626 | ): |
| 1627 | super().__init__() |
| 1628 | self.daemon = daemon |
| 1629 | self.pubsub = pubsub |
| 1630 | self.sleep_time = sleep_time |
| 1631 | self.exception_handler = exception_handler |
| 1632 | self.sharded_pubsub = sharded_pubsub |
| 1633 | self._running = threading.Event() |
| 1634 | |
| 1635 | def run(self) -> None: |
| 1636 | if self._running.is_set(): |
Callers
nothing calls this directly
Tested by
no test coverage detected