Skip to content

pipeline

pipeline(s1): Planner

Defined in: packages/engine/src/lib/planner/pipeline.ts:30

Composes stages into a Planner, feeding each stage’s output to the next. The first stage takes PlanningInput, the last produces a PlannerCandidate, and every adjacent pair must agree on the type in between; a mismatch is a compile error at the offending argument.

Every stage receives the same StageContext, and runs wrapped by its StageContext.instrument: once per request, just before it runs, under the name given with named or stage-<index>. The first Err (a Deferred or an EngineError) stops the pipeline and is returned unchanged. If the request’s signal aborts while a stage is running, the next stage does not start and the pipeline returns a CancellationError.

Accepts one to nine stages.

Planner

Planner

const planner = pipeline(selectVessels, arrangeLayout);

pipeline<A>(s1, s2): Planner

Defined in: packages/engine/src/lib/planner/pipeline.ts:31

Composes stages into a Planner, feeding each stage’s output to the next. The first stage takes PlanningInput, the last produces a PlannerCandidate, and every adjacent pair must agree on the type in between; a mismatch is a compile error at the offending argument.

Every stage receives the same StageContext, and runs wrapped by its StageContext.instrument: once per request, just before it runs, under the name given with named or stage-<index>. The first Err (a Deferred or an EngineError) stops the pipeline and is returned unchanged. If the request’s signal aborts while a stage is running, the next stage does not start and the pipeline returns a CancellationError.

Accepts one to nine stages.

A

Stage<PlanningInput, A>

Stage<A, PlannerCandidate>

Planner

const planner = pipeline(selectVessels, arrangeLayout);

pipeline<A, B>(s1, s2, s3): Planner

Defined in: packages/engine/src/lib/planner/pipeline.ts:35

Composes stages into a Planner, feeding each stage’s output to the next. The first stage takes PlanningInput, the last produces a PlannerCandidate, and every adjacent pair must agree on the type in between; a mismatch is a compile error at the offending argument.

Every stage receives the same StageContext, and runs wrapped by its StageContext.instrument: once per request, just before it runs, under the name given with named or stage-<index>. The first Err (a Deferred or an EngineError) stops the pipeline and is returned unchanged. If the request’s signal aborts while a stage is running, the next stage does not start and the pipeline returns a CancellationError.

Accepts one to nine stages.

A

B

Stage<PlanningInput, A>

Stage<A, B>

Stage<B, PlannerCandidate>

Planner

const planner = pipeline(selectVessels, arrangeLayout);

pipeline<A, B, C>(s1, s2, s3, s4): Planner

Defined in: packages/engine/src/lib/planner/pipeline.ts:40

Composes stages into a Planner, feeding each stage’s output to the next. The first stage takes PlanningInput, the last produces a PlannerCandidate, and every adjacent pair must agree on the type in between; a mismatch is a compile error at the offending argument.

Every stage receives the same StageContext, and runs wrapped by its StageContext.instrument: once per request, just before it runs, under the name given with named or stage-<index>. The first Err (a Deferred or an EngineError) stops the pipeline and is returned unchanged. If the request’s signal aborts while a stage is running, the next stage does not start and the pipeline returns a CancellationError.

Accepts one to nine stages.

A

B

C

Stage<PlanningInput, A>

Stage<A, B>

Stage<B, C>

Stage<C, PlannerCandidate>

Planner

const planner = pipeline(selectVessels, arrangeLayout);

pipeline<A, B, C, D>(s1, s2, s3, s4, s5): Planner

Defined in: packages/engine/src/lib/planner/pipeline.ts:46

Composes stages into a Planner, feeding each stage’s output to the next. The first stage takes PlanningInput, the last produces a PlannerCandidate, and every adjacent pair must agree on the type in between; a mismatch is a compile error at the offending argument.

Every stage receives the same StageContext, and runs wrapped by its StageContext.instrument: once per request, just before it runs, under the name given with named or stage-<index>. The first Err (a Deferred or an EngineError) stops the pipeline and is returned unchanged. If the request’s signal aborts while a stage is running, the next stage does not start and the pipeline returns a CancellationError.

Accepts one to nine stages.

A

B

C

D

Stage<PlanningInput, A>

Stage<A, B>

Stage<B, C>

Stage<C, D>

Stage<D, PlannerCandidate>

Planner

const planner = pipeline(selectVessels, arrangeLayout);

pipeline<A, B, C, D, E>(s1, s2, s3, s4, s5, s6): Planner

Defined in: packages/engine/src/lib/planner/pipeline.ts:53

Composes stages into a Planner, feeding each stage’s output to the next. The first stage takes PlanningInput, the last produces a PlannerCandidate, and every adjacent pair must agree on the type in between; a mismatch is a compile error at the offending argument.

Every stage receives the same StageContext, and runs wrapped by its StageContext.instrument: once per request, just before it runs, under the name given with named or stage-<index>. The first Err (a Deferred or an EngineError) stops the pipeline and is returned unchanged. If the request’s signal aborts while a stage is running, the next stage does not start and the pipeline returns a CancellationError.

Accepts one to nine stages.

A

B

C

D

E

Stage<PlanningInput, A>

Stage<A, B>

Stage<B, C>

Stage<C, D>

Stage<D, E>

Stage<E, PlannerCandidate>

Planner

const planner = pipeline(selectVessels, arrangeLayout);

pipeline<A, B, C, D, E, F>(s1, s2, s3, s4, s5, s6, s7): Planner

Defined in: packages/engine/src/lib/planner/pipeline.ts:61

Composes stages into a Planner, feeding each stage’s output to the next. The first stage takes PlanningInput, the last produces a PlannerCandidate, and every adjacent pair must agree on the type in between; a mismatch is a compile error at the offending argument.

Every stage receives the same StageContext, and runs wrapped by its StageContext.instrument: once per request, just before it runs, under the name given with named or stage-<index>. The first Err (a Deferred or an EngineError) stops the pipeline and is returned unchanged. If the request’s signal aborts while a stage is running, the next stage does not start and the pipeline returns a CancellationError.

Accepts one to nine stages.

A

B

C

D

E

F

Stage<PlanningInput, A>

Stage<A, B>

Stage<B, C>

Stage<C, D>

Stage<D, E>

Stage<E, F>

Stage<F, PlannerCandidate>

Planner

const planner = pipeline(selectVessels, arrangeLayout);

pipeline<A, B, C, D, E, F, G>(s1, s2, s3, s4, s5, s6, s7, s8): Planner

Defined in: packages/engine/src/lib/planner/pipeline.ts:70

Composes stages into a Planner, feeding each stage’s output to the next. The first stage takes PlanningInput, the last produces a PlannerCandidate, and every adjacent pair must agree on the type in between; a mismatch is a compile error at the offending argument.

Every stage receives the same StageContext, and runs wrapped by its StageContext.instrument: once per request, just before it runs, under the name given with named or stage-<index>. The first Err (a Deferred or an EngineError) stops the pipeline and is returned unchanged. If the request’s signal aborts while a stage is running, the next stage does not start and the pipeline returns a CancellationError.

Accepts one to nine stages.

A

B

C

D

E

F

G

Stage<PlanningInput, A>

Stage<A, B>

Stage<B, C>

Stage<C, D>

Stage<D, E>

Stage<E, F>

Stage<F, G>

Stage<G, PlannerCandidate>

Planner

const planner = pipeline(selectVessels, arrangeLayout);

pipeline<A, B, C, D, E, F, G, H>(s1, s2, s3, s4, s5, s6, s7, s8, s9): Planner

Defined in: packages/engine/src/lib/planner/pipeline.ts:80

Composes stages into a Planner, feeding each stage’s output to the next. The first stage takes PlanningInput, the last produces a PlannerCandidate, and every adjacent pair must agree on the type in between; a mismatch is a compile error at the offending argument.

Every stage receives the same StageContext, and runs wrapped by its StageContext.instrument: once per request, just before it runs, under the name given with named or stage-<index>. The first Err (a Deferred or an EngineError) stops the pipeline and is returned unchanged. If the request’s signal aborts while a stage is running, the next stage does not start and the pipeline returns a CancellationError.

Accepts one to nine stages.

A

B

C

D

E

F

G

H

Stage<PlanningInput, A>

Stage<A, B>

Stage<B, C>

Stage<C, D>

Stage<D, E>

Stage<E, F>

Stage<F, G>

Stage<G, H>

Stage<H, PlannerCandidate>

Planner

const planner = pipeline(selectVessels, arrangeLayout);