Documentation / @agentick/kernel / pipe
Function: pipe() ​
Call Signature ​
pipe<
T1>(p1):Procedure<T1>
Defined in: kernel/src/procedure.ts:1669
Pipe multiple procedures together, passing the output of each to the next.
Type Parameters ​
T1 ​
T1 extends (...args) => any
Parameters ​
p1 ​
Procedure<T1>
Returns ​
Procedure<T1>
Example ​
const parse = createProcedure(async (json: string) => JSON.parse(json));
const validate = createProcedure(async (data: unknown) => schema.parse(data));
const transform = createProcedure(async (valid: Valid) => transform(valid));
// Create a pipeline that parses, validates, then transforms
const pipeline = pipe(parse, validate, transform);
const result = await pipeline('{"name": "test"}');Call Signature ​
pipe<
T1,T2>(p1,p2):Procedure<(...args) =>Promise<ExtractReturn<T2>>>
Defined in: kernel/src/procedure.ts:1670
Pipe multiple procedures together, passing the output of each to the next.
Type Parameters ​
T1 ​
T1 extends (...args) => any
T2 ​
T2 extends (arg) => any
Parameters ​
p1 ​
Procedure<T1>
p2 ​
Procedure<T2>
Returns ​
Procedure<(...args) => Promise<ExtractReturn<T2>>>
Example ​
const parse = createProcedure(async (json: string) => JSON.parse(json));
const validate = createProcedure(async (data: unknown) => schema.parse(data));
const transform = createProcedure(async (valid: Valid) => transform(valid));
// Create a pipeline that parses, validates, then transforms
const pipeline = pipe(parse, validate, transform);
const result = await pipeline('{"name": "test"}');Call Signature ​
pipe<
T1,T2,T3>(p1,p2,p3):Procedure<(...args) =>Promise<ExtractReturn<T3>>>
Defined in: kernel/src/procedure.ts:1677
Pipe multiple procedures together, passing the output of each to the next.
Type Parameters ​
T1 ​
T1 extends (...args) => any
T2 ​
T2 extends (arg) => any
T3 ​
T3 extends (arg) => any
Parameters ​
p1 ​
Procedure<T1>
p2 ​
Procedure<T2>
p3 ​
Procedure<T3>
Returns ​
Procedure<(...args) => Promise<ExtractReturn<T3>>>
Example ​
const parse = createProcedure(async (json: string) => JSON.parse(json));
const validate = createProcedure(async (data: unknown) => schema.parse(data));
const transform = createProcedure(async (valid: Valid) => transform(valid));
// Create a pipeline that parses, validates, then transforms
const pipeline = pipe(parse, validate, transform);
const result = await pipeline('{"name": "test"}');Call Signature ​
pipe<
T1,T2,T3,T4>(p1,p2,p3,p4):Procedure<(...args) =>Promise<ExtractReturn<T4>>>
Defined in: kernel/src/procedure.ts:1686
Pipe multiple procedures together, passing the output of each to the next.
Type Parameters ​
T1 ​
T1 extends (...args) => any
T2 ​
T2 extends (arg) => any
T3 ​
T3 extends (arg) => any
T4 ​
T4 extends (arg) => any
Parameters ​
p1 ​
Procedure<T1>
p2 ​
Procedure<T2>
p3 ​
Procedure<T3>
p4 ​
Procedure<T4>
Returns ​
Procedure<(...args) => Promise<ExtractReturn<T4>>>
Example ​
const parse = createProcedure(async (json: string) => JSON.parse(json));
const validate = createProcedure(async (data: unknown) => schema.parse(data));
const transform = createProcedure(async (valid: Valid) => transform(valid));
// Create a pipeline that parses, validates, then transforms
const pipeline = pipe(parse, validate, transform);
const result = await pipeline('{"name": "test"}');Call Signature ​
pipe<
T1,T2,T3,T4,T5>(p1,p2,p3,p4,p5):Procedure<(...args) =>Promise<ExtractReturn<T5>>>
Defined in: kernel/src/procedure.ts:1697
Pipe multiple procedures together, passing the output of each to the next.
Type Parameters ​
T1 ​
T1 extends (...args) => any
T2 ​
T2 extends (arg) => any
T3 ​
T3 extends (arg) => any
T4 ​
T4 extends (arg) => any
T5 ​
T5 extends (arg) => any
Parameters ​
p1 ​
Procedure<T1>
p2 ​
Procedure<T2>
p3 ​
Procedure<T3>
p4 ​
Procedure<T4>
p5 ​
Procedure<T5>
Returns ​
Procedure<(...args) => Promise<ExtractReturn<T5>>>
Example ​
const parse = createProcedure(async (json: string) => JSON.parse(json));
const validate = createProcedure(async (data: unknown) => schema.parse(data));
const transform = createProcedure(async (valid: Valid) => transform(valid));
// Create a pipeline that parses, validates, then transforms
const pipeline = pipe(parse, validate, transform);
const result = await pipeline('{"name": "test"}');