Expand description
user request — broadcast an outbound request to every connected
user stream (GET /user) and BLOCK until the first ACCEPTED reply
(or the base --timeout elapses).
The daemon holds the request PENDING even with zero connected
streams — a user surface that connects later receives it on
replay. An optional --validate-python snippet gates replies:
it runs with the full reply ({"identity": …, "reply": …}) as its
input and must end in a trailing expression evaluating True
for the reply to be accepted; anything else (False, no output, an
exception) rejects it and the request stays pending. Without the
base --timeout the wait is UNCAPPED.
Modules§
Structs§
- Args
- Command
- Listener
Execution - One
/listenbroadcast run ofuser request: the actualRequest, the producer’sAgentArguments, and the unary response future. Seecrate::cli::broadcast_listener. - Request
- Response
- The winning reply.