Class BrokenComm

Declaration

class BrokenComm(Comm)

▶ def abort(self) override
inherited doc Close the communication immediately and abruptly. Useful in destructors or generators' ``finally`` blocks.
source link
This method overrides distributed.comm.core.Comm.abort.
▶ def close(self) override
inherited doc Close the communication cleanly. This will attempt to flush outgoing buffers before actually closing the underlying transport.
source link
This method overrides distributed.comm.core.Comm.close.
```
This method is a coroutine.
```
▶ def closed(self) override
inherited doc Return whether the stream is closed.
source link
This method overrides distributed.comm.core.Comm.closed.
▶ def read(self, deserializers=None) override
inherited doc Read and return a message (a Python object).
source link
This method overrides distributed.comm.core.Comm.read.
```
This method is a coroutine.
```
Parameters
- deserializers : Optional[Dict[str, Tuple[Callable, Callable, bool]]]
```
An optional dict appropriate for distributed.protocol.deserialize.
See :ref:`serialization` for more.
```
▶ def write(self, msg, serializers=None, on_error=None) override
inherited doc Write a message (a Python object).
source link
This method overrides distributed.comm.core.Comm.write.
```
This method is a coroutine.
```
Parameters
- msg :
- on_error : Optional[str]
```
The behavior when serialization fails. See
``distributed.protocol.core.dumps`` for valid values.
```