Module core

distributed.comm.core

Classes

class Comm
A message-oriented communication object, representing an established
class CommClosedError
class Connector
class FatalCommClosedError
class Listener

Functions

▶ def listen(addr, handle_comm, deserialize=True, **kwargs)
Create a listener object with the given parameters. When its ``start()``
source link
```
method is called, the listener will listen on the given address
(a URI such as ``tcp://0.0.0.0``) and call *handle_comm* with a
``Comm`` object for each incoming connection.

*handle_comm* can be a regular function or a coroutine.
```
Reexports
- Imported in distributed.comm.
- Imported in distributed.comm.tests.test_comms.
- Imported in distributed.comm.tests.test_ucx.
- Imported in distributed.core.
- Imported in distributed.tests.test_batched.
- Imported in distributed.tests.test_security.