diff --git a/apps/presentation/dashboard/src/data/chat.ts b/apps/presentation/dashboard/src/data/chat.ts
index 1a77682671..cb80a308a9 100644
--- a/apps/presentation/dashboard/src/data/chat.ts
+++ b/apps/presentation/dashboard/src/data/chat.ts
@@ -642,6 +642,7 @@ export async function createChatSession(
   agentId?: string,
   mode: "resume_latest" | "new" = "resume_latest",
   contextKind: "goal" | "manager" = "goal",
+  signal?: AbortSignal,
 ) {
   return requestJson<{
     agent_id: string;
@@ -651,7 +652,7 @@ export async function createChatSession(
     session_id: string;
     session: ChatSessionSummary;
   }>("/api/chat/sessions", {
-    method: "POST",
+    method: "POST", signal,
     // An omitted ``agent_id`` means "no explicit executor pick": the channel
     // owner resolves its own default. Sending this client's own default would
     // silently re-point the steward channel away from its configured executor.
diff --git a/apps/presentation/dashboard/src/features/personal-workspace/channel-timeline.tsx b/apps/presentation/dashboard/src/features/personal-workspace/channel-timeline.tsx
index 2f543b125c..19a9a59bf1 100644
--- a/apps/presentation/dashboard/src/features/personal-workspace/channel-timeline.tsx
+++ b/apps/presentation/dashboard/src/features/personal-workspace/channel-timeline.tsx
@@ -1,9 +1,9 @@
+import { MessageActivity } from "./message-activity";
 import { GoalDraftCard } from "./goal-draft-card";
 import type { GoalDraft } from "../../../../../../loopx/control_plane/collaboration/goal_draft.js";
-import {Fragment, useRef, useState} from "react";
-import { ChatApiError } from "../../data/chat.js";
+import {Fragment} from "react";
 import { CollaborationCard } from "./collaboration-card";
-import { Activity, Bot, Sparkles, Square } from "lucide-react";
+import { Activity, Bot, Sparkles } from "lucide-react";
 
 import { AttentionRow } from "./cards/attention-row";
 import { MIN_SEPARATE_ANSWER_LENGTH } from "./answer-text";
@@ -15,7 +15,7 @@ import { useWorkspaceI18n } from "./i18n";
 import { ReturnDeliveryStatus } from "./return-delivery-status";
 import {ManagerTeamResult} from "./manager-team-result";
 import { compareProposalRecency } from "./proposal-recency";
-import type { WorkspaceDrawerSelection, WorkspaceGoal, WorkspaceMessage, WorkspaceTimelineItem } from "./personal-workspace-model";
+import type { WorkspaceDrawerSelection, WorkspaceGoal, WorkspaceTimelineItem } from "./personal-workspace-model";
 
 function answerLink(sessionId: string, messageId: string) {
   const url = new URL(window.location.href);
@@ -26,80 +26,6 @@ function answerLink(sessionId: string, messageId: string) {
   return url.toString();
 }
 
-function MessageActivity({ message, onInterruptTurn, onSteerTurn }: {
-  message: WorkspaceMessage;
-  onInterruptTurn?: (turnId: string) => Promise<void>;
-  onSteerTurn?: (turnId: string, text: string, ingressId: string) => Promise<void>;
-}) {
-  const { locale, t } = useWorkspaceI18n();
-  const zh = locale === "zh-CN";
-  const [stopping, setStopping] = useState(false);
-  const [error, setError] = useState<string | null>(null);
-  const [editing, setEditing] = useState(false);
-  const [draft, setDraft] = useState("");
-  const [steering, setSteering] = useState(false);
-  const [steerError, setSteerError] = useState<string | null>(null);
-  const [steerReceipt, setSteerReceipt] = useState(false);
-  const request = useRef<{ text: string; id: string } | null>(null);
-  const activity = message.activity ?? [];
-  async function steer() {
-    const text = draft.trim();
-    if (!text || !message.pending || !message.sourceTurnId || !onSteerTurn || steering) return;
-    // Retain the operation identity after a lost response; retry cannot deliver twice.
-    if (request.current?.text !== text) request.current = { text, id: crypto.randomUUID() };
-    setSteering(true);
-    setSteerError(null);
-    try {
-      await onSteerTurn(message.sourceTurnId, text, request.current.id);
-      setDraft(""); setEditing(false); setSteerReceipt(true); request.current = null;
-    } catch (cause) {
-      const definitelyNotDelivered = cause instanceof ChatApiError && cause.payload.delivery_state === "not_delivered";
-      if (definitelyNotDelivered) request.current = null;
-      const message = cause instanceof Error ? cause.message : (zh ? "未确认接收，草稿已保留。" : "Delivery unconfirmed. Draft retained.");
-      setSteerError(definitelyNotDelivered
-        ? (zh ? "本次未送达；请检查当前回合与执行器，条件恢复后可重试原文。" : "Not delivered; check the current turn and executor, then retry the unchanged draft.")
-        : message);
-    } finally { setSteering(false); }
-  }
-  async function interrupt() {
-    if (!message.sourceTurnId || !onInterruptTurn || stopping) return;
-    setStopping(true);
-    setError(null);
-    try { await onInterruptTurn(message.sourceTurnId); }
-    catch (cause) { setError(cause instanceof Error ? cause.message : (zh ? "中断失败，请重试。" : "Could not interrupt. Try again.")); }
-    finally { setStopping(false); }
-  }
-  return <div className="personal-message-work">
-    {message.pending ? <div className="personal-message-work-current">
-      <span className="personal-message-pending">{activity.at(-1) || t("timeline.pending")}</span>
-      <span className="personal-message-work-actions">
-      {message.sourceTurnId && onSteerTurn ? <button type="button" disabled={steering || stopping} onClick={() => { setEditing(!editing); setSteerReceipt(false); }} aria-expanded={editing}>
-        {zh ? "调整本轮" : "Adjust turn"}
-      </button> : null}
-      {message.sourceTurnId && onInterruptTurn ? <button type="button" disabled={stopping} onClick={() => void interrupt()}>
-        <Square size={12} aria-hidden="true"/>{stopping ? (zh ? "正在中断…" : "Interrupting…") : (zh ? "中断本轮" : "Interrupt turn")}
-      </button> : null}
-      </span>
-    </div> : null}
-    {editing ? <form className="personal-message-steer" onSubmit={event => { event.preventDefault(); void steer(); }}>
-      <label>{zh ? "追加给本轮的指令" : "Instructions for this turn"}<textarea value={draft} maxLength={12000} disabled={steering}
-        onChange={event => setDraft(event.target.value)} rows={3}/></label>
-      <span>{message.pending
-        ? (zh ? "调整当前工作，保持原有任务与会话。" : "Adjust the current work in this conversation.")
-        : (zh ? "本轮已结束，草稿已保留；可复制到输入框作为新消息发送。" : "This turn ended. Copy the retained draft to the composer to send a new message.")}</span>
-      <button type="submit" disabled={!message.pending || !draft.trim() || steering || stopping}>
-        {steering ? (zh ? "正在发送…" : "Sending…") : (zh ? "发送调整" : "Send adjustment")}
-      </button>
-      {steerError ? <p className="personal-message-work-error" role="alert">{steerError}</p> : null}
-    </form> : null}
-    {steerReceipt ? <p className="personal-message-steer-receipt" role="status">{zh ? "执行器已接收本轮追加指令。" : "The executor accepted instructions for this turn."}</p> : null}
-    {activity.length ? <details className="personal-message-activity">
-      <summary>{zh ? "最近活动" : "Recent activity"}<span>{activity.length}</span></summary>
-      <ol>{activity.map((label, index) => <li key={`${index}:${label}`}>{label}</li>)}</ol>
-    </details> : null}
-    {message.pending && error ? <p className="personal-message-work-error" role="alert">{error}</p> : null}
-  </div>;
-}
 
 export function ChannelTimeline({
   items,
@@ -111,8 +37,10 @@ export function ChannelTimeline({
   onOpenGoalEvidence,
   onInterruptTurn,
   onSteerTurn,
+  onCancelPreparation,
 }: {
   items: WorkspaceTimelineItem[];
+  onCancelPreparation?: () => void;
   onSelect: (selection: WorkspaceDrawerSelection) => void;
   selectedGoal: WorkspaceGoal | null;
   showManagerTeamResults?: boolean;
@@ -217,7 +145,7 @@ export function ChannelTimeline({
             ? <a className="personal-answer-link" href={answerLink(item.message.sourceSessionId, item.message.sourceMessageId)}
                 target="_blank" rel="noopener noreferrer">{locale === "zh-CN" ? "单独阅读完整答复" : "Read full answer separately"}</a>
             : null}
-          {item.message.role !== "user" && (item.message.pending || item.message.sourceTurnId || item.message.activity?.length) ? <MessageActivity message={item.message} onInterruptTurn={onInterruptTurn} onSteerTurn={onSteerTurn}/> : null}
+          {item.message.role !== "user" && (item.message.pending || item.message.sourceTurnId || item.message.activity?.length) ? <MessageActivity message={item.message} onCancelPreparation={onCancelPreparation} onInterruptTurn={onInterruptTurn} onSteerTurn={onSteerTurn}/> : null}
           {item.message.role === "assistant" && !item.message.pending && item.message.goalDraft
             ? <GoalDraftCard draftId={`${item.message.sourceSessionId ?? ""}:${item.message.id}`} draft={item.message.goalDraft} onReview={onReviewGoalDraft} onSuggest={onSuggestReply}/> : null}
           <CollaborationCard request={item.message.collaboration} />
diff --git a/apps/presentation/dashboard/src/features/personal-workspace/message-activity.tsx b/apps/presentation/dashboard/src/features/personal-workspace/message-activity.tsx
new file mode 100644
index 0000000000..cf10c8b4de
--- /dev/null
+++ b/apps/presentation/dashboard/src/features/personal-workspace/message-activity.tsx
@@ -0,0 +1,105 @@
+import { useEffect, useRef, useState } from "react";
+import { Square } from "lucide-react";
+import { ChatApiError } from "../../data/chat.js";
+import { useWorkspaceI18n } from "./i18n";
+import type { WorkspaceMessage } from "./personal-workspace-model";
+
+// One work surface for the conversation timeline and compact overview receipt.
+export function MessageActivity({ message, onInterruptTurn, onSteerTurn, onCancelPreparation }: {
+  message: WorkspaceMessage;
+  onCancelPreparation?: () => void;
+  onInterruptTurn?: (turnId: string) => Promise<void>;
+  onSteerTurn?: (turnId: string, text: string, ingressId: string) => Promise<void>;
+}) {
+  const { locale } = useWorkspaceI18n();
+  const zh = locale === "zh-CN";
+  const [stopping, setStopping] = useState(false);
+  const [error, setError] = useState<string | null>(null);
+  const [editing, setEditing] = useState(false);
+  const [draft, setDraft] = useState("");
+  const [steering, setSteering] = useState(false);
+  const [steerError, setSteerError] = useState<string | null>(null);
+  const [steerReceipt, setSteerReceipt] = useState(false);
+  const request = useRef<{ text: string; id: string } | null>(null);
+  const activity = message.activity ?? [];
+  const [now, setNow] = useState(() => Date.now());
+  useEffect(() => {
+    if (!message.pending) return;
+    setNow(Date.now());
+    const timer = window.setInterval(() => setNow(Date.now()), 1000);
+    return () => window.clearInterval(timer);
+  }, [message.pending]);
+  const elapsed = message.startedAt === undefined ? null
+    : Math.max(0, Math.floor(((message.endedAt ?? now) - message.startedAt) / 1000));
+  const duration = elapsed === null ? null : elapsed < 60 ? `${elapsed}${zh ? "秒" : "s"}`
+    : `${Math.floor(elapsed / 60)}${zh ? "分" : "m "}${elapsed % 60}${zh ? "秒" : "s"}`;
+  const quiet = message.updatedAt !== undefined && now - message.updatedAt >= 20000;
+
+  async function steer() {
+    const text = draft.trim();
+    if (!text || !message.pending || !message.sourceTurnId || !onSteerTurn || steering) return;
+    // Retain the operation identity after a lost response; retry cannot deliver twice.
+    if (request.current?.text !== text) request.current = { text, id: crypto.randomUUID() };
+    setSteering(true);
+    setSteerError(null);
+    try {
+      await onSteerTurn(message.sourceTurnId, text, request.current.id);
+      setDraft(""); setEditing(false); setSteerReceipt(true); request.current = null;
+    } catch (cause) {
+      const definitelyNotDelivered = cause instanceof ChatApiError && cause.payload.delivery_state === "not_delivered";
+      if (definitelyNotDelivered) request.current = null;
+      const message = cause instanceof Error ? cause.message : (zh ? "未确认接收，草稿已保留。" : "Delivery unconfirmed. Draft retained.");
+      setSteerError(definitelyNotDelivered
+        ? (zh ? "本次未送达；请检查当前回合与执行器，条件恢复后可重试原文。" : "Not delivered; check the current turn and executor, then retry the unchanged draft.")
+        : message);
+    } finally { setSteering(false); }
+  }
+  async function interrupt() {
+    if (!message.sourceTurnId || !onInterruptTurn || stopping) return;
+    setStopping(true);
+    setError(null);
+    try { await onInterruptTurn(message.sourceTurnId); }
+    catch (cause) { setError(cause instanceof Error ? cause.message : (zh ? "中断失败，请重试。" : "Could not interrupt. Try again.")); }
+    finally { setStopping(false); }
+  }
+  return <div className="personal-message-work">
+    {message.pending ? <div className="personal-message-work-current">
+      <span className="personal-message-work-status">
+        <span className="personal-message-pending">{activity.at(-1) || (zh ? "等待执行器更新" : "Waiting for executor update")}</span>
+        {duration ? <span className="personal-message-elapsed" aria-live="off">{zh ? "已用时 " : "Elapsed "}{duration}</span> : null}
+      </span>
+      <span className="personal-message-work-actions">
+      {message.preparing && onCancelPreparation ? <button type="button" onClick={onCancelPreparation}>
+        <Square size={12} aria-hidden="true"/>{zh ? "取消发送" : "Cancel send"}
+      </button> : null}
+      {message.sourceTurnId && onSteerTurn ? <button type="button" disabled={steering || stopping} onClick={() => { setEditing(!editing); setSteerReceipt(false); }} aria-expanded={editing}>
+        {zh ? "调整本轮" : "Adjust turn"}
+      </button> : null}
+      {message.sourceTurnId && onInterruptTurn ? <button type="button" disabled={stopping} onClick={() => void interrupt()}>
+        <Square size={12} aria-hidden="true"/>{stopping ? (zh ? "正在中断…" : "Interrupting…") : (zh ? "中断本轮" : "Interrupt turn")}
+      </button> : null}
+      </span>
+    </div> : null}
+    {message.pending && quiet ? <p className="personal-message-quiet" role="status">{zh
+      ? "暂时没有新的进展，仍在等待执行器更新。"
+      : "No new activity yet. Waiting for the executor to update."}</p> : null}
+    {editing ? <form className="personal-message-steer" onSubmit={event => { event.preventDefault(); void steer(); }}>
+      <label>{zh ? "追加给本轮的指令" : "Instructions for this turn"}<textarea value={draft} maxLength={12000} disabled={steering}
+        onChange={event => setDraft(event.target.value)} rows={3}/></label>
+      <span>{message.pending
+        ? (zh ? "调整当前工作，保持原有任务与会话。" : "Adjust the current work in this conversation.")
+        : (zh ? "本轮已结束，草稿已保留；可复制到输入框作为新消息发送。" : "This turn ended. Copy the retained draft to the composer to send a new message.")}</span>
+      <button type="submit" disabled={!message.pending || !draft.trim() || steering || stopping}>
+        {steering ? (zh ? "正在发送…" : "Sending…") : (zh ? "发送调整" : "Send adjustment")}
+      </button>
+      {steerError ? <p className="personal-message-work-error" role="alert">{steerError}</p> : null}
+    </form> : null}
+    {steerReceipt ? <p className="personal-message-steer-receipt" role="status">{zh ? "执行器已接收本轮追加指令。" : "The executor accepted instructions for this turn."}</p> : null}
+    {!message.pending && message.endedAt && duration ? <p className="personal-message-elapsed">{zh ? "已结束 · 用时 " : "Ended · Elapsed "}{duration}</p> : null}
+    {activity.length ? <details className="personal-message-activity">
+      <summary>{zh ? "最近活动" : "Recent activity"}<span>{activity.length}</span></summary>
+      <ol>{activity.map((label, index) => <li key={`${index}:${label}`}>{label}</li>)}</ol>
+    </details> : null}
+    {message.pending && error ? <p className="personal-message-work-error" role="alert">{error}</p> : null}
+  </div>;
+}
diff --git a/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-model.ts b/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-model.ts
index 7c37004c64..4edd5b8978 100644
--- a/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-model.ts
+++ b/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-model.ts
@@ -293,6 +293,11 @@ export type WorkspaceMessage = {
   attachments?: WorkspaceImageAttachment[];
   id: string;
   pending?: boolean;
+  preparing?: boolean;
+  /** Observed request/turn times, independent of component mount or view changes. */
+  startedAt?: number;
+  updatedAt?: number;
+  endedAt?: number;
   returnDelivery?: WorkspaceReturnDelivery;
   role: "assistant" | "user" | "system";
   sourceTurnId?: string;
@@ -420,6 +425,7 @@ export type PersonalWorkspaceCallbacks = {
   onExplainDecision?: (attention: WorkspaceAttention) => void | Promise<void>;
   onExportOutput?: (output: WorkspaceOutput) => void | Promise<void>;
   onInterruptRun?: (run: WorkspaceRun) => void | Promise<void>;
+  onCancelConversationPreparation?: (contextId: string) => void;
   onInterruptConversationTurn?: (contextId: string, turnId: string) => Promise<void>;
   onSteerConversationTurn?: (contextId: string, turnId: string, message: string, ingressId: string) => Promise<void>;
   onOpenGoal?: (goalId: string) => void | Promise<void>;
diff --git a/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-page.tsx b/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-page.tsx
index a6b2deb0ae..1654983b67 100644
--- a/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-page.tsx
+++ b/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace-page.tsx
@@ -37,6 +37,7 @@ import { GoalLoopXMode } from "./goal-loopx-mode";
 import { GoalTeamResults } from "./goal-team-results";
 import { GoalManagedResults } from "./goal-managed-results";
 import { sendLoopXMessage, type LoopXModeSnapshot } from "../../data/chat";
+import { MessageActivity } from "./message-activity";
 import { ChannelTimeline } from "./channel-timeline";
 import { ContextDrawer } from "./context-drawer";
 import { GoalSidebar } from "./goal-sidebar";
@@ -263,6 +264,9 @@ function ManagerConversationTray({
   onReviewGoalDraft,
   onSuggestReply,
   onOpenConversation,
+  onInterruptTurn,
+  onSteerTurn,
+  onCancelPreparation,
   title,
 }: {
   agentLabel?: string;
@@ -272,6 +276,9 @@ function ManagerConversationTray({
   onReviewGoalDraft?: (draft: GoalDraft, edit?: boolean, draftId?: string) => Promise<void>;
   onSuggestReply?: (text: string) => void;
   onOpenConversation: () => void;
+  onInterruptTurn?: (turnId: string) => Promise<void>;
+  onSteerTurn?: (turnId: string, text: string, ingressId: string) => Promise<void>;
+  onCancelPreparation?: () => void;
   title?: string;
 }) {
   const { t } = useWorkspaceI18n();
@@ -329,7 +336,7 @@ function ManagerConversationTray({
             <strong>{message.role === "user" ? t("common.you") : message.agentLabel ?? agentLabel ?? t("header.manager")}</strong>
             <div className="personal-manager-conversation-bubble">
               {message.role === "user" ? <p>{message.text}</p> : <MarkdownText text={message.text} />}
-              {message.pending ? <small>{t("conversation.agentPending")}</small> : null}
+              {message.role === "assistant" ? <MessageActivity message={message} onInterruptTurn={onInterruptTurn} onSteerTurn={onSteerTurn} onCancelPreparation={onCancelPreparation} /> : null}
               {message.role === "assistant" && !message.pending && message.goalDraft ? <GoalDraftCard draftId={`${message.sourceSessionId ?? ""}:${message.id}`} draft={message.goalDraft} onReview={onReviewGoalDraft} onSuggest={onSuggestReply}/> : null}
               <CollaborationCard request={message.collaboration} />
               <ReturnDeliveryStatus delivery={message.returnDelivery} />
@@ -799,6 +806,8 @@ export function PersonalWorkspacePage({
   const digestSinceRef = useRef(Number.NaN);
   const composerRef = useRef<HTMLTextAreaElement>(null);
   const channelScrollRef = useRef<HTMLDivElement>(null);
+  const followConversationRef = useRef(true);
+  const [showLatestMessage, setShowLatestMessage] = useState(false);
   const settingsReturnFocusRef = useRef<HTMLElement | null>(null);
   const imageInputRef = useRef<HTMLInputElement>(null);
   const lifecyclePendingGoalIdsRef = useRef(new Set<string>());
@@ -812,6 +821,12 @@ export function PersonalWorkspacePage({
     setImageAttachments([]);
     setImageAttachmentError(null);
   }, [composerDraftKey]);
+  useEffect(() => {
+    const input = composerRef.current;
+    if (!input) return;
+    input.style.height = "auto";
+    input.style.height = `${Math.min(input.scrollHeight, 120)}px`;
+  }, [composer, selectedGoalId, managerChatOpen]);
   function setComposerDraft(key: string, value: string) {
     setDrafts((current) => {
       const next = { ...current };
@@ -855,12 +870,6 @@ export function PersonalWorkspacePage({
   function stewardPromptText(id: string) {
     return stewardPrompts.find((item) => item.id === id)?.prompt ?? "";
   }
-  useEffect(() => {
-    const el = composerRef.current;
-    if (!el) return;
-    el.style.height = "auto";
-    el.style.height = `${Math.min(el.scrollHeight, 120)}px`;
-  }, [composer]);
   const workspaceGoals = useMemo(() => model.goals.map((goal) => {
     const repository = goalContexts[goal.goalId];
     return repository ? {
@@ -1001,15 +1010,26 @@ export function PersonalWorkspacePage({
         || managerChannelProposalIds.includes(item.proposal.previewId)))),
     [items, sessionProposalIds, managerChannelProposalIds],
   );
-  const lastChatItem = managerChatItems[managerChatItems.length - 1];
-  const latestMessageTextLength = lastChatItem?.kind === "message" ? lastChatItem.message.text.length : 0;
+  const conversationOpen = selectedGoal ? selectedGoalTab === "chat" : managerChatOpen;
+  const conversationMessages = selectedGoal ? goalMessages : managerMessages;
+  const latestMessage = conversationMessages.at(-1);
+  const latestMessageTextLength = latestMessage?.text.length ?? 0;
+  function scrollToLatestMessage() {
+    followConversationRef.current = true;
+    setShowLatestMessage(false);
+    const scroller = channelScrollRef.current;
+    if (scroller) scroller.scrollTop = scroller.scrollHeight;
+  }
   useEffect(() => {
-    if (!managerChatOpen || !channelScrollRef.current) return;
-    const frame = window.requestAnimationFrame(() => {
-      if (channelScrollRef.current) channelScrollRef.current.scrollTop = channelScrollRef.current.scrollHeight;
-    });
+    followConversationRef.current = true;
+    setShowLatestMessage(false);
+  }, [selectedGoalId, selectedAgentId, conversationOpen]);
+  useEffect(() => {
+    if (!conversationOpen || !followConversationRef.current) return;
+    const frame = window.requestAnimationFrame(scrollToLatestMessage);
     return () => window.cancelAnimationFrame(frame);
-  }, [managerChatItems.length, managerChatOpen, latestMessageTextLength]);
+  }, [conversationOpen, selectedGoalId, selectedAgentId, conversationMessages.length,
+    latestMessageTextLength, latestMessage?.pending, latestMessage?.activity?.length]);
   const drawerSelection = useMemo<Exclude<WorkspaceDrawerSelection, { kind: "settings" }> | null>(() => {
     if (selection?.kind === "settings") return null;
     if (selection?.kind === "attention") return { kind: "attention", item: refreshAttention(selection.item, model.attentionHistory ?? model.userTodos) };
@@ -1572,6 +1592,8 @@ export function PersonalWorkspacePage({
     const pendingImages = messageOverride ? [] : imageAttachments;
     const message = (messageOverride ?? composer).trim() || (pendingImages.length ? t("composer.imageAnalysisPrompt") : "");
     if (!message || sending) return;
+    followConversationRef.current = true;
+    setShowLatestMessage(false);
     if (loopxMode?.session_id === conversationSessionId && loopxMode?.enabled && loopxMode.active_turn_id && conversationSessionId) {
       if (pendingImages.length) {
         setImageAttachmentError(locale === "zh-CN" ? "运行中的消息投递暂不支持图片，请暂停后发送。" : "Pause execution before sending images.");
@@ -1754,7 +1776,14 @@ export function PersonalWorkspacePage({
               key={`${selectedGoalId}:${selectedAgentId}`} sessionId={conversationSessionId} onChange={setLoopxMode}
               onExecute={(operation, settings) => callbacks.onStartLoopX?.(operation, selectedAgentId, selectedGoalId, settings)}
             /> : null}
-          <div className="personal-channel-scroll" data-active-goal-view={selectedGoal ? selectedGoalTab : undefined} ref={channelScrollRef}>
+          <div className="personal-channel-scroll" data-active-goal-view={selectedGoal ? selectedGoalTab : undefined} ref={channelScrollRef}
+            onScroll={(event) => {
+              if (!conversationOpen) return;
+              const { scrollHeight, scrollTop, clientHeight } = event.currentTarget;
+              const nearBottom = scrollHeight - scrollTop - clientHeight < 64;
+              followConversationRef.current = nearBottom;
+              setShowLatestMessage(!nearBottom);
+            }}>
             {selectedGoalId && selectedGoalTab === "chat" && !readOnly && selectedAgentId === "codex" && conversationSessionId && loopxMode?.settings.execution_config && loopxMode.settings.agent_id ? <GoalTeamResults
               key={`${conversationSessionId}:${loopxMode.settings.agent_id}:${loopxMode.settings.execution_config}`}
               sessionId={conversationSessionId} zh={locale === "zh-CN"}
@@ -1822,6 +1851,8 @@ export function PersonalWorkspacePage({
                       onSteerTurn={!readOnly && callbacks.onSteerConversationTurn
                         ? (turnId, text, ingressId) => callbacks.onSteerConversationTurn!(selectedGoal.goalId, turnId, text, ingressId)
                         : undefined}
+                      onCancelPreparation={!readOnly && callbacks.onCancelConversationPreparation
+                        ? () => callbacks.onCancelConversationPreparation!(selectedGoal.goalId) : undefined}
                       onInterruptTurn={!readOnly && callbacks.onInterruptConversationTurn
                         ? (turnId) => callbacks.onInterruptConversationTurn!(selectedGoal.goalId, turnId)
                         : undefined} />
@@ -1834,6 +1865,8 @@ export function PersonalWorkspacePage({
                 onSteerTurn={!readOnly && callbacks.onSteerConversationTurn
                   ? (turnId, text, ingressId) => callbacks.onSteerConversationTurn!("manager", turnId, text, ingressId)
                   : undefined}
+                onCancelPreparation={!readOnly && callbacks.onCancelConversationPreparation
+                  ? () => callbacks.onCancelConversationPreparation!("manager") : undefined}
                 onInterruptTurn={!readOnly && callbacks.onInterruptConversationTurn
                   ? (turnId) => callbacks.onInterruptConversationTurn!("manager", turnId)
                   : undefined}
@@ -1847,6 +1880,9 @@ export function PersonalWorkspacePage({
             ) : <>
             {!selectedGoal && !managerChatOpen && managerConversationReceiptVisible && managerMessages.length ? (
               <ManagerConversationTray onReviewGoalDraft={reviewGoalDraft} onSuggestReply={suggestReply}
+                onCancelPreparation={!readOnly && callbacks.onCancelConversationPreparation ? () => callbacks.onCancelConversationPreparation!("manager") : undefined}
+                onInterruptTurn={!readOnly && callbacks.onInterruptConversationTurn ? (turnId) => callbacks.onInterruptConversationTurn!("manager", turnId) : undefined}
+                onSteerTurn={!readOnly && callbacks.onSteerConversationTurn ? (turnId, text, ingressId) => callbacks.onSteerConversationTurn!("manager", turnId, text, ingressId) : undefined}
                 messages={managerMessages}
                 onClose={() => setManagerConversationReceiptVisible(false)}
                 onOpenConversation={() => {
@@ -1857,6 +1893,9 @@ export function PersonalWorkspacePage({
             {selectedGoal && selectedGoalTab !== "chat" && goalConversationReceiptVisible && goalMessages.length ? (
               <ManagerConversationTray onReviewGoalDraft={reviewGoalDraft} onSuggestReply={suggestReply}
                 agentLabel={selectedAgentLabel}
+                onCancelPreparation={!readOnly && callbacks.onCancelConversationPreparation ? () => callbacks.onCancelConversationPreparation!(selectedGoal.goalId) : undefined}
+                onInterruptTurn={!readOnly && callbacks.onInterruptConversationTurn ? (turnId) => callbacks.onInterruptConversationTurn!(selectedGoal.goalId, turnId) : undefined}
+                onSteerTurn={!readOnly && callbacks.onSteerConversationTurn ? (turnId, text, ingressId) => callbacks.onSteerConversationTurn!(selectedGoal.goalId, turnId, text, ingressId) : undefined}
                 messages={goalMessages}
                 onClose={() => setGoalConversationReceiptVisible(false)}
                 onDraftTask={selectedGoalTab === "tasks" ? (reply) => {
@@ -1873,7 +1912,10 @@ export function PersonalWorkspacePage({
                 <button aria-label={t("common.closeActionReceipt")} onClick={() => setActionFeedback(null)} type="button"><X size={14} /></button>
               </div>
             ) : null}
-            <details className="personal-composer-tools" key={selectedGoalId ?? "manager"}>
+            {conversationOpen && showLatestMessage ? <button className="personal-conversation-latest" type="button" onClick={scrollToLatestMessage}>
+              {locale === "zh-CN" ? "回到最新消息 ↓" : "Latest message ↓"}
+            </button> : null}
+            {(!conversationOpen || !conversationMessages.length) ? <details className="personal-composer-tools" key={selectedGoalId ?? "manager"}>
               <summary>{locale === "zh-CN" ? "快捷提问" : "Suggestions"}</summary>
             {selectedGoal ? (
               <div className="personal-quick-prompts">
@@ -1890,7 +1932,7 @@ export function PersonalWorkspacePage({
                 <button aria-label={t("composer.createGoal")} onClick={requestGoalCreate} title={t("composer.createGoalHint")} type="button"><Plus size={13} /><span>{t("composer.createGoal")}</span></button>
               </div>
             )}
-            </details>
+            </details> : null}
             {actionDraft ? <WorkspaceActionForm draft={actionDraft} onClose={() => setActionDraft(null)} onPreview={(request) => createPreview(request)} /> : null}
             {imageAttachments.length ? <div className="personal-composer-images" aria-label={t("composer.imagesPending")}>{imageAttachments.map((attachment) => (
               <figure key={attachment.id}>
@@ -1934,13 +1976,16 @@ export function PersonalWorkspacePage({
                   }
                 }}
                 onPaste={handleComposerPaste}
-                placeholder={selectedGoal ? t("composer.goalPlaceholder", { goal: selectedGoal.title }) : t("composer.managerPlaceholder")}
+                placeholder={sending ? (locale === "zh-CN" ? "可以先写下后续问题…" : "Draft your next message…") : selectedGoal ? t("composer.goalPlaceholder", { goal: selectedGoal.title }) : t("composer.managerPlaceholder")}
                 ref={composerRef}
                 rows={1}
                 value={composer}
               />
               <button aria-label={t("composer.send")} disabled={(!composer.trim() && imageAttachments.length === 0) || sending} onClick={() => void sendMessage()} title={t("composer.sendMessageHint")} type="button"><Send size={18} /></button>
             </div>
+            {conversationOpen ? <div className="personal-composer-hint">{sending
+              ? (locale === "zh-CN" ? "正在回复 · 修改当前任务请使用“调整本轮”" : "Reply in progress · use Adjust turn to change the current task")
+              : (locale === "zh-CN" ? "Enter 发送 · Shift+Enter 换行" : "Enter to send · Shift+Enter for a new line")}</div> : null}
             </>}
           </div>
         </div>
diff --git a/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace.css b/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace.css
index 3eb57d6b5b..40b54465d7 100644
--- a/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace.css
+++ b/apps/presentation/dashboard/src/features/personal-workspace/personal-workspace.css
@@ -1914,3 +1914,6 @@
 .personal-action-form-limit { margin: 0; color: var(--pw-amber); font-size: 13px; }
 
 .personal-capability-supported-scopes { margin: 6px 0; color: var(--pw-muted); font-size: 12px; line-height: 1.5; }
+
+.personal-conversation-latest { display: block; margin: 0 auto 10px; padding: 7px 14px; border: 1px solid var(--pw-line); border-radius: 20px; background: var(--pw-bg); color: var(--pw-text); font: inherit; font-size: 12px; cursor: pointer; }
+.personal-composer-hint { padding-top: 7px; color: var(--pw-muted); font-size: 11px; text-align: center; }
diff --git a/apps/presentation/dashboard/src/styles.css b/apps/presentation/dashboard/src/styles.css
index ec412ddbc8..35994dfe54 100644
--- a/apps/presentation/dashboard/src/styles.css
+++ b/apps/presentation/dashboard/src/styles.css
@@ -2328,3 +2328,7 @@ select {
     display: none;
   }
 }
+
+.personal-message-work-status { display: flex; align-items: baseline; flex-wrap: wrap; gap: 0.5rem 1rem; }
+.personal-message-elapsed { color: var(--color-muted, #8f8f8f); font-size: 0.75rem; font-variant-numeric: tabular-nums; white-space: nowrap; }
+.personal-message-quiet { margin: 0.5rem 0 0; font-size: 0.75rem; color: var(--color-muted, #8f8f8f); }
diff --git a/apps/presentation/dashboard/src/views/dashboard-page.tsx b/apps/presentation/dashboard/src/views/dashboard-page.tsx
index c5812a88be..c136cf94c8 100644
--- a/apps/presentation/dashboard/src/views/dashboard-page.tsx
+++ b/apps/presentation/dashboard/src/views/dashboard-page.tsx
@@ -520,6 +520,10 @@ type PersonalManagerMessage = {
   id: number;
   lines: string[];
   pending?: boolean;
+  preparing?: boolean;
+  startedAt?: number;
+  updatedAt?: number;
+  endedAt?: number;
   returnDelivery?: ChatVisibleMessage["return_delivery"];
   collaboration?: ChatVisibleMessage["collaboration"];
   reconnect?: boolean;
@@ -1275,7 +1279,7 @@ function PersonalGoalHome({
   const remoteGoalLifecycleHost = statusSourceControl.activeSource.kind === "ssh_tunnel"
     ? statusSourceControl.activeSource.hostAlias
     : undefined;
-  const { t } = useWorkspaceI18n();
+  const { t, locale } = useWorkspaceI18n();
   const [runtimeAgents, setRuntimeAgents] = useState<Array<{
     adapter_kind: string;
     agent_id: string;
@@ -1411,6 +1415,7 @@ function PersonalGoalHome({
   const newSessionRequired = useRef(new Set<string>());
   const activeTurnIds = useRef(new Map<string, string>());
   const streamControllers = useRef(new Map<string, AbortController>());
+  const preparationControllers = useRef(new Map<string, AbortController>());
   const interruptedTurnIds = useRef(new Set<string>());
   const recoveringTurnKeys = useRef(new Set<string>());
   const agentMenuRef = useRef<HTMLDivElement>(null);
@@ -1693,6 +1698,8 @@ function PersonalGoalHome({
         let streamedText = "";
         const streamingMessageId = appendManagerAssistantMessage(targetContextId, {
           activity: ["正在恢复进行中的 Agent 回合"],
+          startedAt: typeof activeSnapshot?.active_turn?.created_at === "string"
+            ? Date.parse(activeSnapshot.active_turn.created_at) || undefined : undefined,
           sourceTurnId: activeTurnId,
           sourceSessionId: created.session_id,
           agentLabel: answerIdentityLabel(targetContextId, selectedAgent.label),
@@ -1720,6 +1727,7 @@ function PersonalGoalHome({
                     ? message
                     : {
                         ...message,
+                        updatedAt: Date.now(),
                         activity: message.activity?.at(-1) === label ? message.activity : [...(message.activity ?? []), label].slice(-6),
                       }
                 ),
@@ -1976,7 +1984,7 @@ function PersonalGoalHome({
       ...messages,
       [targetContextId]: [
         ...(messages[targetContextId] ?? []),
-        { ...message, id, role: "assistant" },
+        { startedAt: message.pending ? Date.now() : undefined, updatedAt: Date.now(), ...message, id, role: "assistant" },
       ],
     }));
     return id;
@@ -1990,7 +1998,10 @@ function PersonalGoalHome({
     setMessagesByContext((messages) => ({
       ...messages,
       [targetContextId]: (messages[targetContextId] ?? []).map((message) =>
-        message.id === messageId ? { ...message, ...update } : message
+        message.id === messageId ? { ...message, ...update,
+          ...(update.text !== undefined || update.activity !== undefined ? { updatedAt: Date.now() } : {}),
+          ...(message.pending && update.pending === false ? { preparing: false, endedAt: Date.now() } : {}),
+        } : message
       ),
     }));
   }
@@ -2008,11 +2019,11 @@ function PersonalGoalHome({
     }));
   }
 
-  async function prepareGoalConversation(goalId: string, agentId: string) {
+  async function prepareGoalConversation(goalId: string, agentId: string, signal?: AbortSignal) {
     const key = `${goalId}:${agentId}`;
     const existing = sessionIds.current.get(key);
     if (existing) return existing;
-    const session = await createChatSession(goalId, agentId, newSessionRequired.current.has(key) ? "new" : "resume_latest", "goal");
+    const session = await createChatSession(goalId, agentId, newSessionRequired.current.has(key) ? "new" : "resume_latest", "goal", signal);
     sessionIds.current.set(key, session.session_id);
     newSessionRequired.current.delete(key);
     recordRuntimeBinding(goalId, {agentId, resumable: true, sessionId: session.session_id, status: session.session.status});
@@ -2078,11 +2089,18 @@ function PersonalGoalHome({
     }
 
     const sessionKey = `${targetContextId}:${selectedRoute.agentId}`;
-    let streamingMessageId: number | null = null;
+    // Show receipt before session startup: native runtime preparation can be slow.
+    const preparationController = new AbortController();
+    preparationControllers.current.set(targetContextId, preparationController);
+    const streamingMessageId = appendManagerAssistantMessage(targetContextId, {
+      activity: [locale === "zh-CN" ? "已接收，正在连接执行器" : "Received · connecting to the executor"],
+      agentLabel: answerIdentityLabel(targetContextId, selectedRoute.label),
+      lines: [], pending: true, preparing: true, text: "",
+    });
     let submittedTurnId: string | undefined;
     let streamedText = "";
     try {
-      let sessionId = targetContextId === "manager" ? sessionIds.current.get(sessionKey) : await prepareGoalConversation(targetContextId, selectedRoute.agentId);
+      let sessionId = targetContextId === "manager" ? sessionIds.current.get(sessionKey) : await prepareGoalConversation(targetContextId, selectedRoute.agentId, preparationController.signal);
       if (!sessionId) {
         const mode = newSessionRequired.current.has(sessionKey) ? "new" : "resume_latest";
         const sessionEndpoint =
@@ -2092,6 +2110,7 @@ function PersonalGoalHome({
           sessionEndpoint,
           mode,
           targetContextId === "manager" ? "manager" : "goal",
+          preparationController.signal,
         );
         if (targetContextId === "manager" && session.session.manager_runtime) {
           setManagerRuntime(session.session.manager_runtime);
@@ -2106,15 +2125,12 @@ function PersonalGoalHome({
         });
         newSessionRequired.current.delete(sessionKey);
       }
-      streamingMessageId = appendManagerAssistantMessage(targetContextId, {
-        activity: [targetContextId === "manager" ? "正在连接管家" : "正在连接 Agent"],
-        agentLabel: answerIdentityLabel(targetContextId, selectedRoute.label),
-        lines: [],
-        pending: true,
-        sourceLabel: targetContextId !== "manager"
-          ? `${selectedRoute.label} Agent · ${personalGoalTitle(targetGoal!.goalId)}`
-          : `${t("header.manager")} · 跨 Goal`,
-        text: "",
+      preparationController.signal.throwIfAborted();
+      // Cancellation only owns preparation. Once dispatch begins, the server turn
+      // and its acknowledgement own interruption; never claim an unsent request.
+      preparationControllers.current.delete(targetContextId);
+      updateManagerAssistantMessage(targetContextId, streamingMessageId, {
+        preparing: false, activity: [locale === "zh-CN" ? "执行器已连接，正在提交请求" : "Connected · submitting the request"],
       });
       const streamOptions = {
         attachments: route?.attachments,
@@ -2125,14 +2141,9 @@ function PersonalGoalHome({
         })(),
         onDelta: (delta: string) => {
           streamedText += delta;
-          if (streamingMessageId !== null) {
-            updateManagerAssistantMessage(targetContextId, streamingMessageId, {
-              text: streamedText,
-            });
-          }
+          updateManagerAssistantMessage(targetContextId, streamingMessageId, { text: streamedText });
         },
         onActivity: (label: string) => {
-          if (streamingMessageId === null) return;
           setMessagesByContext((messages) => ({
             ...messages,
             [targetContextId]: (messages[targetContextId] ?? []).map((message) =>
@@ -2140,14 +2151,18 @@ function PersonalGoalHome({
                 ? message
                 : {
                     ...message,
+                    updatedAt: Date.now(),
                     activity: message.activity?.at(-1) === label ? message.activity : [...(message.activity ?? []), label].slice(-6),
                   }
             ),
           }));
         },
-        onPhase: (_phase: string, turnId: string) => {
+        onPhase: (phase: string, turnId: string) => {
           submittedTurnId = turnId;
-          if (streamingMessageId !== null) updateManagerAssistantMessage(targetContextId, streamingMessageId, { sourceTurnId: turnId, sourceSessionId: sessionId });
+          updateManagerAssistantMessage(targetContextId, streamingMessageId, {
+            sourceTurnId: turnId, sourceSessionId: sessionId,
+            ...(phase === "turn.accepted" ? { activity: [locale === "zh-CN" ? "请求已接收，等待执行器输出" : "Request accepted · waiting for executor output"] } : {}),
+          });
           activeTurnIds.current.set(targetContextId, turnId);
           recordRuntimeBinding(targetContextId, {
             agentId: selectedRoute.agentId,
@@ -2179,7 +2194,7 @@ function PersonalGoalHome({
       // stored identity before offering a link; a failed read never hides the
       // visible answer or retries the model Turn.
       const completedMessageId = streamingMessageId;
-      if (completedMessageId !== null && (response.message || streamedText).length >= MIN_SEPARATE_ANSWER_LENGTH) {
+      if ((response.message || streamedText).length >= MIN_SEPARATE_ANSWER_LENGTH) {
         void fetchChatSession(sessionId).then((stored) => {
           const answer = stored.messages.find((item) =>
             item.turn_id === streamed.turnId && ["agent", "assistant"].includes(item.role));
@@ -2222,6 +2237,12 @@ function PersonalGoalHome({
         if (protectedPreview) return protectedPreview;
       }
     } catch (error) {
+      if (preparationController.signal.aborted && !submittedTurnId) {
+        updateManagerAssistantMessage(targetContextId, streamingMessageId, {
+          pending: false, preparing: false, text: locale === "zh-CN" ? "已取消发送；请求尚未交给执行器处理。" : "Send cancelled. The request was not submitted to the executor.",
+        });
+        return;
+      }
       const userInterrupted = (submittedTurnId && interruptedTurnIds.current.delete(submittedTurnId))
         || (error instanceof ChatApiError && error.payload.error_code === "turn_interrupted");
       if (userInterrupted) {
@@ -2234,11 +2255,7 @@ function PersonalGoalHome({
             : `${selectedRoute.label} 会话`,
           text: [streamedText.trim(), "已中断。你可以在当前会话继续发送消息。"].filter(Boolean).join("\n\n"),
         };
-        if (streamingMessageId === null) {
-          appendManagerAssistantMessage(targetContextId, interruptedMessage);
-        } else {
-          updateManagerAssistantMessage(targetContextId, streamingMessageId, interruptedMessage);
-        }
+        updateManagerAssistantMessage(targetContextId, streamingMessageId, interruptedMessage);
         return;
       }
       const payloadError = error instanceof ChatApiError ? error.payload : null;
@@ -2267,17 +2284,16 @@ function PersonalGoalHome({
         sourceLabel: "LoopX Chat 本地后端",
         text: payloadError?.error_code === "resume_failed"
           ? `原 ${answerIdentityLabel(targetContextId, selectedRoute.label)} 会话无法恢复。本地历史已经保留，请在运行详情里选择“重试恢复”或“开始新 Session”。`
+          : preparationControllers.current.has(targetContextId)
+            ? `${locale === "zh-CN" ? "尚未提交请求。连接执行器失败，可以重新发送。" : "Request not submitted. Could not connect to the executor; you can send again."}\n\n${error instanceof Error ? error.message : ""}`
           : error instanceof Error
             ? error.message
             : `${answerIdentityLabel(targetContextId, selectedRoute.label)} 会话暂时不可用。`,
       };
-      if (streamingMessageId === null) {
-        appendManagerAssistantMessage(targetContextId, failureMessage);
-      } else {
-        updateManagerAssistantMessage(targetContextId, streamingMessageId, failureMessage);
-      }
+      updateManagerAssistantMessage(targetContextId, streamingMessageId, failureMessage);
     } finally {
       activeTurnIds.current.delete(targetContextId);
+      preparationControllers.current.delete(targetContextId);
       streamControllers.current.delete(targetContextId);
       const boundSessionId = sessionIds.current.get(sessionKey);
       if (boundSessionId) {
@@ -2586,6 +2602,10 @@ function PersonalGoalHome({
           attachments: message.attachments,
         id: String(message.id),
         pending: message.pending,
+        preparing: message.preparing,
+        startedAt: message.startedAt,
+        updatedAt: message.updatedAt,
+        endedAt: message.endedAt,
         returnDelivery: message.returnDelivery,
         collaboration: message.collaboration,
         goalDraft: message.goalDraft,
@@ -2742,6 +2762,10 @@ function PersonalGoalHome({
           },
           onCloseRunSession: closeManagerSession,
           onInterruptRun: async (run) => interruptManagerTurn(run),
+          onCancelConversationPreparation: (targetContextId) => {
+            const pending = messagesByContext[targetContextId]?.at(-1);
+            if (pending?.pending && pending.preparing) preparationControllers.current.get(targetContextId)?.abort();
+          },
           onInterruptConversationTurn: async (targetContextId, turnId) => {
             if (activeTurnIds.current.get(targetContextId) !== turnId) {
               throw new Error("该回合已结束或已被新的回合取代，请刷新后查看。");
diff --git a/docs/architecture/rfcs/app-conversation-and-async-inbox-v0.md b/docs/architecture/rfcs/app-conversation-and-async-inbox-v0.md
index c8b1c20fb8..ce30729e53 100644
--- a/docs/architecture/rfcs/app-conversation-and-async-inbox-v0.md
+++ b/docs/architecture/rfcs/app-conversation-and-async-inbox-v0.md
@@ -95,6 +95,46 @@ return context. First-screen changes still require the repository's preview gate
 No external screenshot, private incident transcript or proprietary asset is
 redistributed by this proposal.
 
+### Waiting is part of the conversation
+
+One shared TypeScript activity surface serves manager and Goal conversations,
+including the compact overview receipt. It appears when the user sends, before
+executor session preparation can block. The shortest journey is send → visible
+receipt → observed work or actionable failure → readable answer in the same place.
+
+- Show the latest reported activity and request elapsed time on one quiet line.
+  Time measures waiting, not percent complete or proof of active computation.
+  View changes retain the request timestamp; recovery uses the recorded turn
+  timestamp when available, and omits duration when it is unknown.
+- Keep tool/phase events in an expandable recent-activity list. Render only
+  upstream observations; never simulate phases, expose hidden reasoning, or
+  infer progress from elapsed time. A period without new events has an explicit
+  waiting caption, not an invented failure or continually changing animation.
+- Before dispatch, cancel only session preparation and state that the request
+  was not submitted. After acceptance, existing exact-turn steering/interrupt
+  controls own effects; stopping observation is not stopping the worker.
+- The compact receipt and full conversation offer the same controls. Failure
+  ends the live indicator, preserves the request/partial answer and names the
+  next supported action. A completed delegation still shows receiver adoption
+  separately; finishing the manager turn does not complete the delegated work.
+
+Primary-source research (2026-09-29), not hands-on certification of other apps:
+[Perplexity Pro Search](https://www.perplexity.ai/help-center/en/articles/10352903-what-is-pro-search)
+documents research decomposition and source links;
+[Cursor Agent](https://cursor.com/docs/agent/overview) distinguishes queued
+follow-ups from steering an active run;
+[Gemini Deep Research](https://support.google.com/gemini/answer/15719111?hl=en)
+documents a reviewable plan and completion notification. Borrow observability,
+control and clear completion boundaries, not provider-specific activity names.
+Notifications and durable cross-restart timing remain separate acceptance;
+a browser timer does not implement either.
+
+Decisive regression: delay executor connection, cancel before dispatch, retry
+through startup failure, then observe a streamed turn while switching between
+overview and conversation. Verify stable elapsed time, quiet waiting, exact-turn
+controls, preserved partial output and no duplicate submission. Exercise the
+packaged UI with synthetic fixtures and qualify the chosen real query separately.
+
 ## Current owners and gaps
 
 | Boundary inspected | Existing implementation | Gap to address through that owner |
@@ -381,3 +421,8 @@ prompt/case hashes, request settings, token usage and repeat count. This layer
 qualifies model interpretation of supplied evidence, not live discovery, actual
 dispatch, stop enforcement or full GQ01/GQ02 completion. Packaged browser and
 real collaboration transport tests qualify those separate boundaries.
+
+The same conversation surface preserves reading position during streaming: output
+follows only while the reader stays near the bottom, and a latest-message action
+restores following. Multiline drafts expand within a bounded composer; suggestions
+remain on overview/empty entry states rather than displacing an active conversation.
diff --git a/docs/architecture/rfcs/app-conversation-and-async-inbox-v0.zh-CN.md b/docs/architecture/rfcs/app-conversation-and-async-inbox-v0.zh-CN.md
index bc1fcfe568..c2a314ffa4 100644
--- a/docs/architecture/rfcs/app-conversation-and-async-inbox-v0.zh-CN.md
+++ b/docs/architecture/rfcs/app-conversation-and-async-inbox-v0.zh-CN.md
@@ -63,6 +63,32 @@ LoopX 还必须核验综合结果返回原请求。这些是文档陈述，非
 保留键盘访问、阅读位置和返回上下文。首屏改动仍须遵循仓库预览门禁。
 本设计不重新分发外部截图、私有事故记录或专有素材。
 
+### 等待也是对话的一部分
+
+管家、Goal 对话和总览里的紧凑回执共用一个 TypeScript 活动组件。
+用户发送后立即显示接收反馈，不等执行器会话准备完毕才出现。最短路径是：
+发送 → 看见接收 → 真实活动或可处理的失败 → 在原处读到答案。
+
+- 用一行显示最近报告的活动和已用时间。时间表示等待时长，不表示完成比例或
+  持续计算的证明。切换视图保留起始时间；恢复时使用已记录的回合时间，未知则不编造。
+- 工具和阶段记录可展开，只显示上游报告的信息，不模拟阶段或暴露隐藏推理。
+  一段时间没有新事件时明确说明仍在等待，不推断失败，也不靠动画假装有进展。
+- 提交前只能取消准备，并说明请求尚未提交；接收后复用精确回合的纠偏与中断。
+  停止观察不等于停止执行器。总览回执和完整对话提供相同的操作。
+- 失败停止实时状态，保留原请求和部分答案，并说明下一步。管家回合结束与
+  接收方采用、完成委派分别显示，不能把“已交办”算作任务完成。
+
+2026-09-29 核对的一手资料（并非对其他产品的实机验收）：
+[Perplexity Pro Search](https://www.perplexity.ai/help-center/en/articles/10352903-what-is-pro-search)
+说明问题拆解和来源链接；[Cursor Agent](https://cursor.com/docs/agent/overview)
+区分排队追问与执行中纠偏；[Gemini Deep Research](https://support.google.com/gemini/answer/15719111?hl=en)
+提供计划审阅与完成通知。借鉴可见性、可控性和完成边界，不照搬特定场景的阶段文案。
+通知与跨重启的持久计时仍需独立验收，浏览器计时器不代表已实现这些能力。
+
+决定性回归：延迟连接，提交前取消，重试并遇到启动失败，再在实际流式回合中切换
+总览与完整对话；验证时间连续、静默等待、精确回合操作、部分答案保留且不重复提交。
+打包 UI 使用合成数据验证，选中的真实查询另行验收。
+
 ## 当前归属与缺口
 
 | 已检查边界 | 现有实现 | 经现有 owner 解决的缺口 |
@@ -242,3 +268,6 @@ App 历史与重连读取同一条消息；managed 和 attached 完成存储均
 完整草稿直接进入类型化 `goal.create` 预览，只需一次显式应用；修改是可选入口，复用同一请求构造器和既有表单。信息不全的草稿可继续补充。同一来源消息与草稿重开预览保持操作身份，另一条消息则是另一请求。草稿默认只读且不启用 heartbeat，原显式创建入口保持默认行为。工作区、负责人、权限检查继续生效；创建不代表执行或交付。Lark 共享语义回答与委派行为，草稿卡片和直接预览仅在 App 提供，不增加 capability、provider 或调度器。
 
 [公开模型评测](../../../examples/evaluations/chat-intake.py) 仅在 release 候选版本验收时显式启用付费调用，默认及新增宣传的模型配置分别至少重复两次。平时 PR、每次提交和 heartbeat 只跑离线回归及受影响的浏览器场景，不运行付费评测。记录候选版本，保留失败；凭证不可用记为跳过，不视为通过。评测使用生产 prompt/parser 和固定公开上下文，覆盖新建、已有负责人、多候选、停止/无授权、纠偏、当前 Goal 追问、引用、否定、普通问答与中英文表达。冲突操作、协议缺失、生成截断均记录为失败。记录模型、prompt/用例哈希、请求参数、token 用量和重复次数，不泄露凭证。该层只验证模型解释已提供证据，不证明真实发现、派发、停止执行或完整 GQ01/GQ02；打包浏览器和实际委派传输测试分别覆盖其边界。
+
+同一对话界面在用户停留底部时跟随输出，上翻阅读后保持位置，并提供回到最新消息的入口。
+多行草稿在有界输入框中展开；快捷提问留在总览或空对话入口，避免挤占当前对话。
diff --git a/examples/personal-workspace-browser-smoke.mjs b/examples/personal-workspace-browser-smoke.mjs
index d1cc4b1b8a..af4eeddb2f 100644
--- a/examples/personal-workspace-browser-smoke.mjs
+++ b/examples/personal-workspace-browser-smoke.mjs
@@ -47,7 +47,9 @@ import { goalDraftScenario } from "./personal-workspace-browser/goal-draft.mjs";
 import { larkCliMissingScenario } from "./personal-workspace-browser/lark-cli-missing.mjs";
 import { executionServiceOfflineScenario } from "./personal-workspace-browser/execution-service-offline.mjs";
 
-const scenarioCatalog = [goalDraftScenario, capabilityScopeScenario, stewardGroupTriggerScenario, conversationInputScenario, goalActivityScenario, conversationActivityScenario, navigationSortingScenario, automationCadenceScenario, chatRecoveryScenario, conversationReturnContinuityScenario, answerPresentationScenario, loopxModeScenario, teamEvidenceScenario, managedGoalResultsScenario, typedActionsScenario, teamPlanScenario, stewardJourneyScenario, executionChipScenario, stewardModelSettingsScenario, progressiveLoadingScenario, workspaceLocaleScenario, newestDraftScenario, larkCliMissingScenario, executionServiceOfflineScenario];
+import { conversationStartupScenario } from "./personal-workspace-browser/conversation-startup.mjs";
+
+const scenarioCatalog = [conversationStartupScenario,goalDraftScenario, capabilityScopeScenario, stewardGroupTriggerScenario, conversationInputScenario, goalActivityScenario, conversationActivityScenario, navigationSortingScenario, automationCadenceScenario, chatRecoveryScenario, conversationReturnContinuityScenario, answerPresentationScenario, loopxModeScenario, teamEvidenceScenario, managedGoalResultsScenario, typedActionsScenario, teamPlanScenario, stewardJourneyScenario, executionChipScenario, stewardModelSettingsScenario, progressiveLoadingScenario, workspaceLocaleScenario, newestDraftScenario, larkCliMissingScenario, executionServiceOfflineScenario];
 const requestedScenario = process.env.LOOPX_PERSONAL_WORKSPACE_SCENARIO;
 const scenarios = requestedScenario
   ? scenarioCatalog.filter((scenario) => scenario.id === requestedScenario)
diff --git a/examples/personal-workspace-browser/chat-recovery.mjs b/examples/personal-workspace-browser/chat-recovery.mjs
index 12cbc7ba0f..c096b20286 100644
--- a/examples/personal-workspace-browser/chat-recovery.mjs
+++ b/examples/personal-workspace-browser/chat-recovery.mjs
@@ -37,7 +37,7 @@ export const chatRecoveryScenario = {
         await new Promise((resolveWait) => setTimeout(resolveWait, 50));
       }
       if (!api.turnRequests.some((turn) => turn.message.includes("汇总所有活跃 Goal 的最新进展与阻塞"))) throw new Error("Progress report shortcut did not send a useful scoped request");
-      while (await page.getByRole("button", { name: "汇总所有 Goal 进展" }).isDisabled()) await new Promise((resolveWait) => setTimeout(resolveWait, 50));
+      await page.locator(".personal-message-pending").waitFor({ state: "hidden" });
       await page.locator(".personal-manager-conversation-tray").waitFor({ state: "visible" });
       if (!(await page.locator(".personal-home-lanes").isVisible())) throw new Error("Manager send replaced the home lane overview");
       const managerUrlBefore = page.url();
@@ -88,7 +88,7 @@ export const chatRecoveryScenario = {
       await page.screenshot({ path: resolve(outputDir, "manager-chat.png"), fullPage: false, animations: "disabled" });
       await page.getByLabel("向 LoopX 发送消息").fill("请把库存方案交给 worker，保留预留两件的修订，并请同伴独立复核后回报。");
       await page.getByRole("button", { name: "发送", exact: true }).click();
-      while (await page.getByRole("button", { name: "汇总所有 Goal 进展" }).isDisabled()) await new Promise((resolveWait) => setTimeout(resolveWait, 50));
+      await page.locator(".personal-message-pending").waitFor({ state: "hidden" });
       await page.screenshot({ path: resolve(outputDir, "collaboration-before.png"), fullPage: false, animations: "disabled" });
       const returnSessionId = api.turnRequests.at(-1).sessionId;
       const turnsBeforeReturn = api.turnRequests.length;
diff --git a/examples/personal-workspace-browser/conversation-activity.mjs b/examples/personal-workspace-browser/conversation-activity.mjs
index 88c97194a9..7939f1e690 100644
--- a/examples/personal-workspace-browser/conversation-activity.mjs
+++ b/examples/personal-workspace-browser/conversation-activity.mjs
@@ -34,6 +34,19 @@ export const conversationActivityScenario = {
       };
       const turn = await send("请检查当前任务状态，并说明下一步。");
       const pending = page.locator(".personal-message").filter({ has: page.getByRole("button", { name: "中断本轮", exact: true }) });
+      await page.clock.install();
+      await page.clock.fastForward(25000);
+      await pending.locator(".personal-message-quiet").waitFor();
+      const elapsedBefore = await pending.locator(".personal-message-elapsed").textContent();
+      await page.getByRole("navigation", { name: "管家视图" }).getByRole("button", { name: "总览", exact: true }).click();
+      const tray = page.locator(".personal-manager-conversation-tray");
+      await tray.getByRole("button", { name: "中断本轮", exact: true }).waitFor();
+      assert.equal(await tray.locator(".personal-message-elapsed").textContent(), elapsedBefore, "view switch keeps request elapsed time");
+      await tray.locator(".personal-message-quiet").waitFor();
+      await page.screenshot({ path: resolve(outputDir, "conversation-waiting-overview.png"), animations: "disabled" });
+      await tray.getByRole("button", { name: "查看完整对话", exact: true }).click();
+      assert.equal(await pending.locator(".personal-message-elapsed").textContent(), elapsedBefore);
+      await page.clock.resume();
       const adjustments = [];
       await page.route("**/steer", async route => {
         const body = route.request().postDataJSON();
@@ -68,7 +81,7 @@ export const conversationActivityScenario = {
       assert.equal(streams.size, 1, "steering keeps the original output stream");
       assert.equal(await page.locator(".personal-message.is-user").filter({ hasText: "先核对依赖" }).count(), 1);
       await pending.locator("summary").filter({ hasText: "最近活动" }).click();
-      assert.deepEqual(await pending.locator(".personal-message-activity li").allTextContents(), ["正在连接管家", "Agent 正在执行命令", "Agent 正在检索", "Agent 正在执行命令"]);
+      assert.deepEqual((await pending.locator(".personal-message-activity li").allTextContents()).slice(-3), ["Agent 正在执行命令", "Agent 正在检索", "Agent 正在执行命令"]);
       await page.screenshot({ path: resolve(outputDir, "conversation-activity-desktop.png"), animations: "disabled" });
       await page.setViewportSize({ width: 390, height: 844 });
       await pending.scrollIntoViewIfNeeded();
@@ -76,6 +89,20 @@ export const conversationActivityScenario = {
       await page.screenshot({ path: resolve(outputDir, "conversation-activity-mobile.png"), animations: "disabled" });
       await page.setViewportSize({ width: 1512, height: 982 });
 
+      // Streaming must not take the reading position away from the user.
+      const live = streams.get(`/events/${turn.sessionId}/${turn.turnId}`);
+      live.write(event(5, "answer.delta", { text: "\n\n" + "公开资料与待核实事项。\n\n".repeat(80) }));
+      await page.getByText("公开资料与待核实事项。", { exact: true }).first().waitFor();
+      const scroller = page.locator(".personal-channel-scroll");
+      await scroller.evaluate(node => { node.scrollTop = 0; node.dispatchEvent(new Event("scroll")); });
+      await page.getByRole("button", { name: "回到最新消息 ↓", exact: true }).waitFor();
+      live.write(event(6, "answer.delta", { text: "新增证据已经到达。" }));
+      await page.getByText("新增证据已经到达。", { exact: true }).waitFor({ state: "attached" });
+      assert.ok(await scroller.evaluate(node => node.scrollTop < 10), "new output preserves upward reading position");
+      await page.getByRole("button", { name: "回到最新消息 ↓", exact: true }).click();
+      assert.ok(await scroller.evaluate(node => node.scrollHeight - node.scrollTop - node.clientHeight < 64));
+      assert.equal(await page.locator(".personal-composer-tools").count(), 0, "conversation removes redundant suggestion strip");
+
       let interrupts = 0;
       const rejectThenMismatch = async route => {
         interrupts += 1;
diff --git a/examples/personal-workspace-browser/conversation-input.mjs b/examples/personal-workspace-browser/conversation-input.mjs
index 601907c21f..99f65a3a7a 100644
--- a/examples/personal-workspace-browser/conversation-input.mjs
+++ b/examples/personal-workspace-browser/conversation-input.mjs
@@ -11,6 +11,13 @@ export const conversationInputScenario = {
     const { page, api, errors, close } = context;
     try {
       const composer = page.getByLabel("向 LoopX 发送消息");
+      const singleLineHeight = (await composer.boundingBox()).height;
+      await composer.fill("第一行\n第二行\n第三行\n第四行");
+      await page.waitForFunction(() => document.querySelector('textarea[aria-label="向 LoopX 发送消息"]').clientHeight > 70);
+      assert.ok((await composer.boundingBox()).height > singleLineHeight, "multiline draft grows without hiding text");
+      await composer.press("Shift+Enter");
+      assert.equal(api.turnRequests.length, 0, "newline does not submit the draft");
+      await composer.fill("");
       async function send(text) {
         const count = api.turnRequests.length;
         const previews = api.actionPreviews.length;
@@ -19,7 +26,7 @@ export const conversationInputScenario = {
         await page.getByRole("button", { name: "发送", exact: true }).click();
         const deadline = Date.now() + 10_000;
         while (api.turnRequests.length === count && Date.now() < deadline) await page.waitForTimeout(25);
-        await page.waitForFunction(() => !document.querySelector('.personal-quick-prompts button')?.disabled);
+        await page.locator(".personal-message-pending").waitFor({state: "hidden"});
         assert.equal(api.turnRequests.length, count + 1, `Request did not reach Chat exactly once: ${text}`);
         assert.equal(api.turnRequests.at(-1).message, text);
         assert.equal(api.actionPreviews.length, previews, `Browser manufactured a preview: ${text}`);
@@ -41,6 +48,7 @@ export const conversationInputScenario = {
       const previews = api.actionPreviews.length;
       const writes = api.durableWriteCount;
       await composer.fill("这段话还没发，不要丢。");
+      await page.getByRole("navigation", { name: "Goal 视图" }).getByRole("button", { name: /^(Overview|概览)$/ }).click();
       await page.locator(".personal-composer-tools > summary").click();
       await page.getByRole("button", { name: "配置定时检查", exact: true }).click();
       const schedule = page.getByRole("dialog", { name: "配置定时检查", exact: true });
diff --git a/examples/personal-workspace-browser/conversation-startup.mjs b/examples/personal-workspace-browser/conversation-startup.mjs
new file mode 100644
index 0000000000..dd6407f07e
--- /dev/null
+++ b/examples/personal-workspace-browser/conversation-startup.mjs
@@ -0,0 +1,49 @@
+import assert from "node:assert/strict";
+import { openWorkspacePage } from "./scenario-context.mjs";
+
+// A slow executor connection must never make a submitted message look lost.
+export const conversationStartupScenario = {
+  id: "conversation-startup",
+  async run({ browser, collectCoverage, url }) {
+    const waiting = [];
+    let fail = false;
+    const context = await openWorkspacePage(browser, url, {
+      collectCoverage, gotoWaitUntil: "domcontentloaded",
+      beforeGoto: async (_api, page) => {
+        await page.route("**/api/chat/sessions", async route => {
+          if (route.request().method() !== "POST") return route.fallback();
+          if (!fail) await new Promise(resolve => waiting.push(resolve));
+          if (fail) return route.fulfill({ status: 503, json: { ok: false, error_code: "host_gate", error: "Executor connection timed out." } });
+          return route.fallback();
+        });
+      },
+    });
+    const { page, api } = context;
+    try {
+      const send = async text => {
+        await page.getByLabel("向 LoopX 发送消息").fill(text);
+        await page.getByRole("button", { name: "发送", exact: true }).click();
+      };
+      await send("帮我整理研究目标，先不要执行。");
+      const tray = page.locator(".personal-manager-conversation-tray");
+      await tray.locator(".personal-message-work-current").getByText("已接收，正在连接执行器", { exact: true }).waitFor();
+      assert.equal(api.turnRequests.length, 0, "receipt precedes executor connection and turn submission");
+      await tray.getByRole("button", { name: "取消发送", exact: true }).click();
+      await tray.getByText("已取消发送；请求尚未交给执行器处理。", { exact: true }).waitFor();
+      await page.getByLabel("向 LoopX 发送消息").fill("重试整理目标。");
+      assert.equal(await page.getByRole("button", { name: "发送", exact: true }).isEnabled(), true);
+      fail = true;
+      waiting.splice(0).forEach(resolve => resolve());
+      assert.equal(api.turnRequests.length, 0, "cancelled preparation cannot dispatch a turn");
+      await send("重试整理目标。");
+      await tray.getByText("尚未提交请求。连接执行器失败，可以重新发送。", { exact: false }).waitFor();
+      assert.equal(await tray.getByRole("button", { name: "中断本轮", exact: true }).count(), 0, "no invented turn control after startup failure");
+      assert.equal(await tray.locator(".personal-message-work-current").count(), 0, "failed preparation stops presenting live progress");
+      assert.equal(api.turnRequests.length, 0);
+      return { coverageEntries: context.coverageEntries, note: "Immediate preparation receipt, pre-dispatch cancellation, retry and honest startup failure through the overview conversation." };
+    } finally {
+      waiting.splice(0).forEach(resolve => resolve());
+      await context.close();
+    }
+  },
+};
diff --git a/examples/personal-workspace-browser/goal-draft.mjs b/examples/personal-workspace-browser/goal-draft.mjs
index 2db8bd6e08..62ffe825ab 100644
--- a/examples/personal-workspace-browser/goal-draft.mjs
+++ b/examples/personal-workspace-browser/goal-draft.mjs
@@ -15,7 +15,7 @@ export const goalDraftScenario = {
       async function send(text) {
         await composer.fill(text);
         await page.getByRole("button", {name: "发送", exact: true}).click();
-        await page.waitForFunction(() => !document.querySelector('.personal-quick-prompts button')?.disabled);
+        await page.locator(".personal-message-pending").waitFor({state: "hidden"});
       }
       await send("解释一下 Goal 是什么");
       assert.equal(await page.locator(".personal-goal-draft").count(), 0);
diff --git a/examples/personal-workspace-browser/typed-actions.mjs b/examples/personal-workspace-browser/typed-actions.mjs
index 0fccc0eba6..1b38dfafb9 100644
--- a/examples/personal-workspace-browser/typed-actions.mjs
+++ b/examples/personal-workspace-browser/typed-actions.mjs
@@ -1563,7 +1563,7 @@ export const typedActionsScenario = {
       const naturalTodoRequest = "添加一个「补充回归测试」普通 Todo，并交给 Codex。不要设置 Heartbeat，也不要创建定时检查";
       await composer.fill(naturalTodoRequest);
       await page.getByRole("button", { name: "发送", exact: true }).click();
-      await page.waitForFunction(() => !document.querySelector('.personal-quick-prompts button')?.disabled);
+      await page.locator(".personal-message-pending").waitFor({state: "hidden"});
       if (api.actionPreviews.length !== beforeNaturalTodo || api.turnRequests.at(-1)?.message !== naturalTodoRequest) throw new Error("Natural Todo request was intercepted before Chat");
 
       const previewCountBeforeAnalysis = api.actionPreviews.length;
@@ -1602,7 +1602,7 @@ export const typedActionsScenario = {
       const beforeNaturalBinding = api.actionPreviews.length;
       await composer.fill("让 Claude Code 负责管理这个 Goal");
       await page.getByRole("button", { name: "发送", exact: true }).click();
-      await page.waitForFunction(() => !document.querySelector('.personal-quick-prompts button')?.disabled);
+      await page.locator(".personal-message-pending").waitFor({state: "hidden"});
       if (api.actionPreviews.length !== beforeNaturalBinding || api.turnRequests.at(-1)?.message !== "让 Claude Code 负责管理这个 Goal") throw new Error("Assignment was interpreted by browser rules");
 
       const selectedGoalId = new URL(page.url()).searchParams.get("goalId");
@@ -1770,6 +1770,8 @@ export const typedActionsScenario = {
       await page.getByRole("navigation", { name: "Goal 视图" }).getByRole("button", { name: /^(Chat|对话)$/ }).click();
       await page.getByRole("dialog").filter({ hasText: "确认执行" }).waitFor({ state: "hidden" });
 
+      // Configuration shortcuts live in the overview, outside an active conversation.
+      await goalNavigation.getByRole("button", { name: /^(Overview|概览)$/ }).click();
       const writesBeforeMonitorShortcut = api.durableWriteCount;
       if (await page.locator(".personal-composer-tools").getAttribute("open") === null) await page.locator(".personal-composer-tools > summary").click();
       await page.getByRole("button", { name: "配置定时检查" }).click();