Class BaseTCPListener

Declaration

▶ def __init__(self, address, comm_handler, deserialize=True, allow_offload=True, ...)
def __init__(
self,
address,
comm_handler,
deserialize=True,
allow_offload=True,
default_port=0,
**connection_args,
)
source link
▶ def contact_address(self) override @property
The contact address as a string.
@property
def contact_address(self)
source link
This method overrides distributed.comm.core.Listener.contact_address.
▷ def get_host_port(self)
The listening address as a (host, port) tuple.
source link
▶ def listen_address(self) override @property
The listening address as a string.
@property
def listen_address(self)
source link
This method overrides distributed.comm.core.Listener.listen_address.
▶ def stop(self) override
inherited doc Stop listening. This does not shutdown already established communications, but prevents accepting new ones.
source link
This method overrides distributed.comm.core.Listener.stop.