package Ġus . k un et . pipeline . impl Ċ Ċ import Ġkotlinx . coroutines . run Blocking Ċ import Ġus . k un et . pipeline . Execution Ċ import Ġus . k un et . pipeline . Regular Execution Ċ import Ġus . k un et . pipeline . Step Ċ Ċ /** Ċ Ġ* ĠRepresents Ġa Ġsynchronous Ġpipeline . Ċ Ġ* Ġ@ see ĠImmutable Pipeline Ċ Ġ*/ Ċ open Ġclass ĠImmutable S ynchronous Pipeline < T Ġ: ĠAny >( steps : ĠList < Step < T , ĠRegular Execution < T >> >) Ġ: ĠImmutable Pipeline < T >( steps ) Ġ{ ĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* ĠChannels Ġthe Ġpipeline Ġsynchronous ly . ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġfun Ġchannel Sync ( target : ĠT , Ġcontinue With Le aks : ĠBoolean Ġ= Ġtrue ): ĠExecution < T > Ġ= ĊĠĠĠĠĠĠĠ Ġrun Blocking Ġ{ Ġchannel ( target , Ġcontinue With Le aks ) Ġ} Ċ } Ċ