_WriteWrapper class
Convenience wrapper to track if a connection to a worker process can be written to safely. In other words, checks to make sure the result returned from the last write was read.
Special methods
- def __call__(self, data: typing.Any) -> None
- def __init__(self, write_fn: typing.Callable[[typing.Any], None], read_wrapper: _ReadWrapper) -> None
- Method generated by attrs for class _WriteWrapper.
Properties
- read_wrapper: _ReadWrapper get set del
- write_fn: typing.Callable[[typing.Any], None] get set del