mahos.node.comm.Requester#

class mahos.node.comm.Requester(context: Context, endpoint: str, linger_ms: int, timeout_ms: int | None = None, rep_type: Type[Reply] | None = None, logger=None)#

Class providing request() for REQ-REP pattern communication.

__init__(context: Context, endpoint: str, linger_ms: int, timeout_ms: int | None = None, rep_type: Type[Reply] | None = None, logger=None)#

Methods

__init__(context, endpoint, linger_ms[, ...])

close()

create_socket()

request(msg)

Send request and return reply.