feat: add missing insertStep and insertSink builder methods

core/src/main/java/tech/illuin/pipeline/builder/PayloadPipelineBuilder.java

@@ -208,6 +208,13 @@ public PayloadPipelineBuilder<I> registerStep(StepAssembler<? extends Indexable,
         return this;
     }
 
+    @SuppressWarnings("unchecked")
+    public PayloadPipelineBuilder<I> insertStep(StepAssembler<? extends Indexable, I> builder, int index)
+    {
+        this.steps.add(index, (StepAssembler<Indexable, I>) builder);
+        return this;
+    }
+
     public PayloadPipelineBuilder<I> registerStepAssemblers(List<? extends StepAssembler<? extends Indexable, I>> assemblers)
     {
         for (StepAssembler<? extends Indexable, I> assembler : assemblers)
@@ -247,6 +254,12 @@ public PayloadPipelineBuilder<I> registerSink(SinkAssembler assembler)
         return this;
     }
 
+    public PayloadPipelineBuilder<I> insertSink(SinkAssembler assembler, int index)
+    {
+        this.sinks.add(index, assembler);
+        return this;
+    }
+
     public PayloadPipelineBuilder<I> registerSinks(List<? extends Sink> sinks)
     {
         for (Sink sink : sinks)

core/src/main/java/tech/illuin/pipeline/builder/SimplePipelineBuilder.java

@@ -235,6 +235,12 @@ public SimplePipelineBuilder<I> registerSink(SinkAssembler assembler)
         return this;
     }
 
+    public SimplePipelineBuilder<I> insertSink(SinkAssembler assembler, int index)
+    {
+        this.sinks.add(index, assembler);
+        return this;
+    }
+
     public SimplePipelineBuilder<I> registerSinks(List<? extends Sink> sinks)
     {
         for (Sink sink : sinks)

core/src/test/java/tech/illuin/pipeline/builder/PipelineBuilderTest.java

@@ -55,15 +55,15 @@ public void test__simple()
             .setDefaultStepErrorHandler(stepErrorHandler)
             .setDefaultSinkErrorHandler(sinkErrorHandler)
             .setDefaultEvaluator(resultEvaluator)
-            .registerStep(step1)
             .registerStep(b -> b.step(step2))
             .registerSteps(List.of(step3, step4))
+            .insertStep(b -> b.step(step1), 0)
             .registerStepAssemblers(List.of(
                 b -> b.step(step5),
                 b -> b.step(step6)
             ))
-            .registerSink(sink)
             .registerSinks(List.of(sink, sink))
+            .insertSink(b -> b.sink(sink), 0)
             .registerObserver(stepCounter)
             .registerOnCloseHandler(closeHandler)
         );
@@ -98,8 +98,8 @@ public void test__payload()
                 (payload, results, context) -> new TestResult("2"),
                 (PayloadStep) (payload, results, context) -> new TestResult("3")
             ))
-            .registerSink(sink)
             .registerSinks(List.of(sink, sink))
+            .insertSink(b -> b.sink(sink), 0)
             .registerObserver(stepCounter)
             .registerOnCloseHandler(closeHandler)
         );
@@ -131,20 +131,22 @@ public void test__payload__withAssemblers()
             .setDefaultStepErrorHandler(stepErrorHandler)
             .setDefaultSinkErrorHandler(sinkErrorHandler)
             .setDefaultEvaluator(resultEvaluator)
-            .registerStep(b -> b.withId("step-builder").step(step1))
             .registerStepAssemblers(List.of(
                 b -> b.step(step2),
                 b -> b.step(step3)
             ))
-            .registerSink(b -> b
-                .withId("sink-builder")
-                .sink(sink)
-                .setAsync(true)
-            )
+            .insertStep(b -> b.withId("step-builder").step(step1), 0)
             .registerSinkAssemblers(List.of(
                 b -> b.sink(sink),
                 b -> b.sink(sink).setAsync(true)
             ))
+            .insertSink(
+                b -> b
+                    .withId("sink-builder")
+                    .sink(sink)
+                    .setAsync(true),
+                0
+            )
             .registerOnCloseHandler(closeHandler)
         );