CleanApiArchitecture_02_Pipeline.java

interface Stage<I, O> {
  O process(I input);
}

class Pipeline<I, O> {

    private final Stage<I, O> currentStage;

    Pipeline(Stage<I, O> currentStage) {
        this.currentStage = currentStage;
    }

    <K> Pipeline<I, K> addStage(Stage<O, K> newStage) {
        return new Pipeline<>(input -> newStage.process(currentStage.process(input)));
    }

    O execute(I input) {
        return currentStage.process(input);
    }

}