Class InProcListener

Declaration

class InProcListener(Listener)

▷ def __init__(self, address, comm_handler, deserialize=True)
source link
▷ def connect_threadsafe(self, conn_req)
source link
▶ def contact_address(self) override @property
inherited doc An address this listener can be contacted on. This can be different from `listen_address` if the latter is some wildcard address such as 'tcp://0.0.0.0:123'.
@property
def contact_address(self)
source link
This method overrides distributed.comm.core.Listener.contact_address.
▶ def listen_address(self) override @property
inherited doc The listening address as a URI 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.