RegisteredTransportOutput

CORE · type · 类型合同

Result type of a transport selected by id.

core:plain-text yields string, a registered id yields its declared result, and an id the runner does not know yields unknown rather than a guessed type.

导入

TypeScript

import type { RegisteredTransportOutput } from '@jangts/agent-core/types';

JavaScript

/** @typedef {import('@jangts/agent-core/types').RegisteredTransportOutput} RegisteredTransportOutput */

其他公开入口：@jangts/agent-core/types、@jangts/agent-core/structs。

定义

type RegisteredTransportOutput<Transports extends readonly ModelTransportDefinition[], Id extends string> = string extends Id
  ? unknown
  : Id extends 'core:plain-text'
    ? string
    : [Extract<Transports[number], { readonly id: Id }>] extends [never]
      ? unknown
      : Extract<Transports[number], { readonly id: Id }> extends ModelTransportDefinition<
            infer Value
          >
        ? Value
        : unknown;

泛型参数

类型参数	约束	默认类型
Transports	readonly ModelTransportDefinition[]	—
Id	string	—

使用示例

• ModelRunner：输入可以省写，输出合同保持一致：用真实 Provider 端口执行一次模型交互，返回 value 和本次 invocation。
• 实际请求测量与同次准备快照：需要提前处理上下文时才 prepare；多次测量与最终发送复用同一次传输准备。
• 子执行：隔离记录，共享祖先额度：子 Runner 不继承对话和输出接收器，但不能绕过父级预算、取消和期限。

同一输出的两种输入

入门 · Node.js

TypeScript

import { ModelRunner } from '@jangts/agent-core/model';
const provider = {
  async *stream(messages: readonly { content: string }[]) {
    yield '收到：' + messages.at(-1)!.content;
  },
};
const runner = new ModelRunner({ provider });
const first = await runner.invoke('你好');
const second = await runner.invoke({ input: '你好' });
console.log(first.value, second.value);
console.log(first.invocation.invocationId);

JavaScript

import { ModelRunner } from '@jangts/agent-core/model';
const provider = {
    async *stream(messages) {
        yield '收到：' + messages.at(-1).content;
    },
};
const runner = new ModelRunner({ provider });
const first = await runner.invoke('你好');
const second = await runner.invoke({ input: '你好' });
console.log(first.value, second.value);
console.log(first.invocation.invocationId);

增加预算与请求取消

配置 · Node.js

TypeScript

import { ModelRunner } from '@jangts/agent-core/model';
const provider = {
  async *stream(messages: readonly { content: string }[]) {
    yield '收到：' + messages.at(-1)!.content;
  },
};
const runner = new ModelRunner({ provider, maxCalls: 2, maxInputChars: 4000,
  maxOutputChars: 2000, callTimeoutMs: 15000,
  execution: { signal: AbortSignal.timeout(20000) },
});
const result = await runner.invoke({ input: '你好', stageId: 'reply', maxOutputTokens: 600 });
console.log(result.value, runner.remainingCalls);

JavaScript

import { ModelRunner } from '@jangts/agent-core/model';
const provider = {
    async *stream(messages) {
        yield '收到：' + messages.at(-1).content;
    },
};
const runner = new ModelRunner({ provider, maxCalls: 2, maxInputChars: 4000,
    maxOutputChars: 2000, callTimeoutMs: 15000,
    execution: { signal: AbortSignal.timeout(20000) },
});
const result = await runner.invoke({ input: '你好', stageId: 'reply', maxOutputTokens: 600 });
console.log(result.value, runner.remainingCalls);

相关策略源码

• Core 的基础预算缺省值
• 同次准备与真实输入计量

相关定义

• ModelTransportDefinition