boru

<dependency>    <groupId>com.trendyol</groupId>    <artifactId>boru</artifactId>    <version>1.0.0</version></dependency>

USAGE

Defining Context

interfacePipelineContext {val items:Map<Any,Any>}classTestDataContext :PipelineContext {overrideval items:MutableMap<Any,Any>=mutableMapOf()var intValue:Int=0var text:String?        get()= items.getOrDefault("Text",null).toString()        set(value) {            items["Text"]= value!!        }}

Define Pipeline Steps

classTestWriterStep(privatevaltext:String,) : PipelineStep<TestDataContext> {overridesuspendfunexecute(context:TestDataContext,next:PipelineStepDelegate<TestDataContext>) {        context.text= text        next(context)    }}

Build Pipeline

funcompose() {val pipeline=PipelineBuilder<TestDataContext>()        .usePipelineStep(TestWriterStep("hello"))        .build()val context=TestDataContext()}

funcompose() {val pipeline=PipelineBuilder<TestDataContext>()        .use { context:TestDataContext, next:suspend ()->Unit->            context.text="hello"            next()        }        .build()val context=TestDataContext()}

funcompose() {val pipeline= pipelineBuilder<TestDataContext> {        use { testDataContext:TestDataContext, next:suspend ()->Unit->            context.text="Hello World"            next()        }    }}

Conditions and Branching

funcompose() {val pipeline= pipelineBuilder<TestDataContext> {        usePipelineStepWhen(TestWriterStep("Hello World")) {            it.text=="ExecuteStep"        }    }}

funcomposeMapping() {val pipeline= pipelineBuilder<TestDataContext> {        map({ it.intValue<3 }) {            usePipelineStep(TestWriterStep("one"))            usePipelineStep(TestWriterStep("two"))        }        map({ it.intValue==3 }) {            usePipelineStep(TestWriterStep("three"))        }    }}

Examples