_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.
- def __ne__(self, other)
- Check equality and either forward a NotImplemented or return the result negated.
Properties
- read_wrapper: _ReadWrapper get set del
- write_fn: typing.Callable[[typing.Any], None] get set del