Function drain

e2e/src/clients/agent-chat-tui.ts:141–153

()

const queue: TheaterEvent[] = [];
let draining = false;
const drain = async () => {
  if (draining) return;
  draining = true;
  while (queue.length > 0) {
    const event = queue.shift();
    if (!event) break;
    const keepGoing = await handle(event);
    if (!keepGoing) {
      process.exit(0);
    }
  }
  draining = false;
};

const input = eventsFifo ? createReadStream(eventsFifo) : process.stdin;
createInterface({ input, terminal: false }).on("line", (line) => {