Delivery: sequential delivery with an explicit end
Each delivery stage explicitly continues or completes; once a stage completes, the run ends immediately.
defineDelivery accepts createState, stages, missingResult, and an optional beforeStage. deliver(input, execution) synchronously returns a Result. beforeStage runs interleaved with that stage's handle; it does not run every hook first and then the handlers. When no stage delivers anything, the error returned by missingResult() is thrown.
AbortSignal is checked before and after execution, and every handler must be synchronous. Stage names, state, priority, and whether publication is allowed are App semantics, not a global Core delivery protocol.
Progressive examples for the same business case
Deliver a piece of text that is already confirmed
Beginner · Node.js
ts
import { Delivery } from '@jangts/agent-core/kits/delivery';
const delivery = Delivery.defineDelivery({
createState: (input: string) => ({ text: input }),
stages: [{ id: 'publish', handle: (state: { text: string }) => ({ type: 'complete' as const, value: state.text }) }],
missingResult: () => new Error('没有可交付结果'),
});
console.log(delivery.deliver('已完成的答复', { signal: new AbortController().signal }));js
import { Delivery } from '@jangts/agent-core/kits/delivery';
const delivery = Delivery.defineDelivery({
createState: (input) => ({ text: input }),
stages: [{ id: 'publish', handle: (state) => ({ type: 'complete', value: state.text }) }],
missingResult: () => new Error('没有可交付结果'),
});
console.log(delivery.deliver('已完成的答复', { signal: new AbortController().signal }));Add a validation stage while keeping the same deliver
Configuration · Node.js
ts
import { Delivery } from '@jangts/agent-core/kits/delivery';
const delivery = Delivery.defineDelivery({
createState: (input: string) => ({ text: input.trim() }),
stages: [
{ id: 'check', handle(state: { text: string }) {
if (!state.text) throw new Error('答复为空');
return { type: 'continue' as const };
} },
{ id: 'publish', handle: (state: { text: string }) => ({ type: 'complete' as const, value: state.text }) },
],
beforeStage: ({ stageId }: { stageId: string }) => { console.log('阶段', stageId); },
missingResult: () => new Error('没有可交付结果'),
});
console.log(delivery.deliver(' 已完成的答复 ', { signal: new AbortController().signal }));js
import { Delivery } from '@jangts/agent-core/kits/delivery';
const delivery = Delivery.defineDelivery({
createState: (input) => ({ text: input.trim() }),
stages: [
{ id: 'check', handle(state) {
if (!state.text)
throw new Error('答复为空');
return { type: 'continue' };
} },
{ id: 'publish', handle: (state) => ({ type: 'complete', value: state.text }) },
],
beforeStage: ({ stageId }) => { console.log('阶段', stageId); },
missingResult: () => new Error('没有可交付结果'),
});
console.log(delivery.deliver(' 已完成的答复 ', { signal: new AbortController().signal }));