_ReadWrapper class
Convenience wrapper to track if a connection to a worker process should have something to read.
Special methods
- def __call__(self) -> typing.Any
- def __init__(self, read_fn: typing.Callable[[], typing.Any], rank: int, is_waiting: bool = False) -> None
- Method generated by attrs for class _ReadWrapper.
Properties
- is_waiting: bool get set del
- rank: int get set del
- read_fn: typing.Callable[[], typing.Any] get set del