Function createReceiverTask

client/src/lib/hooks/useConnection.ts:877–923

(opts: {
        ttl?: number;
        initialStatus: Task["status"];
        statusMessage?: string;
        pollInterval?: number;
      })

      };

      const createReceiverTask = (opts: {
        ttl?: number;
        initialStatus: Task["status"];
        statusMessage?: string;
        pollInterval?: number;
      }): ReceiverTaskRecord => {
        const taskId = makeTaskId();
        const createdAt = nowIso();
        const ttl = opts.ttl ?? getMCPTaskTtl(config);

        let resolvePayload: (payload: ClientResult) => void = () => undefined;
        let rejectPayload: (reason?: unknown) => void = () => undefined;
        const payloadPromise = new Promise<ClientResult>((resolve, reject) => {
          resolvePayload = resolve;
          rejectPayload = reject;
        });

        const task: Task = {
          taskId,
          status: opts.initialStatus,
          ttl,
          createdAt,
          lastUpdatedAt: createdAt,
          ...(opts.pollInterval !== undefined
            ? { pollInterval: opts.pollInterval }
            : undefined),
          ...(opts.statusMessage ? { statusMessage: opts.statusMessage } : {}),
        };

        const record: ReceiverTaskRecord = {
          task,
          payloadPromise,
          resolvePayload,
          rejectPayload,
        };

        // Cleanup after TTL (best-effort).
        if (ttl !== null && ttl > 0) {
          record.cleanupTimeoutId = setTimeout(() => {
            receiverTasksRef.current.delete(taskId);
          }, ttl);
        }

        receiverTasksRef.current.set(taskId, record);
        void emitTaskStatus(task);
        return record;
      };

      // Server -> client Tasks handlers (receiver side)
      client.setRequestHandler(ListTasksRequestSchema, async () => {