Struct UserInputGate 

pub struct UserInputGate {
    pub steering: Arc<SteeringInbox>,
    /* private fields */
}

Mid-session user-input rendezvous.

When a loop wants to ask the user a question, it parks a oneshot sender here and awaits the receiver; coder.respond takes the sender and fulfills it. At most one request is pending at a time — a loop runs single-threaded, so it cannot have two questions in flight, and coder.respond errors cleanly when nothing is parked. The sender is dropped (which surfaces as a closed channel to the waiter) if the session is cancelled or torn down before the user answers.

Fields

steering: Arc<SteeringInbox>

Implementations

impl UserInputGate

pub fn new() -> Self

pub fn park(&self, prompt: &str) -> Receiver<String>

Park a fresh oneshot for a new question, returning the receiver the caller awaits. Any previously-parked (unanswered) sender is dropped, which closes its receiver — the prior waiter, if somehow still alive, then unblocks with an error rather than hanging forever.

pub fn pending_prompt(&self) -> Option<String>

The prompt of the currently-parked question, if any.

pub fn fulfill(&self, answer: String) -> Result<(), String>

Fulfill the parked request with answer. Returns Err when nothing is pending (so coder.respond can report “no pending request”) or when the waiter has already gone away (cancelled/timed-out).

pub fn clear(&self)

Drop any parked sender (cancellation/teardown): unblocks a waiter with a closed channel.

pub fn is_pending(&self) -> bool

Whether a request is currently parked.

Trait Implementations

impl Default for UserInputGate

fn default() -> Self

Returns the “default value” for a type.