-
@ExperimentalCoroutinesApi() public final class PipelineThe entity representing pipeline. Should be used with piping DSL
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public classPipeline.Companion
-
Method Summary
Modifier and Type Method Description final BooleangetClosed()Indicates wheater this Pipeline has ending element. final UnitsetClosed(Boolean closed)final List<Process>getProcesses()final PipelinethroughProcess(ProcessExecutable process)Adds process to this Pipeline final PipelinethroughLambda(Boolean end, Boolean closeOut, SuspendFunction1<ExecutionContext, Unit> lambda)Adds lambda to this Pipeline final PipelinetoEndChannel(SendChannel<ByteReadPacket> channel)Ends this Pipeline with channel final PipelinetoEndPacket(BytePacketBuilder packetBuilder)Ends this Pipeline with packetBuilder final PipelinetoEndStream(OutputStream stream)Ends this Pipeline with stream final PipelinetoEndStringBuilder(StringBuilder stringBuilder)Ends this Pipeline with stringBuilder final Pipelinejoin()Awaits all processes and jobs in this Pipeline final Pipelinekill()Kills all processes in this Pipeline StringtoString()-
-
Method Detail
-
getProcesses
final List<Process> getProcesses()
-
throughProcess
final Pipeline throughProcess(ProcessExecutable process)
-
throughLambda
final Pipeline throughLambda(Boolean end, Boolean closeOut, SuspendFunction1<ExecutionContext, Unit> lambda)
-
toEndChannel
final Pipeline toEndChannel(SendChannel<ByteReadPacket> channel)
-
toEndPacket
final Pipeline toEndPacket(BytePacketBuilder packetBuilder)
Ends this Pipeline with packetBuilder
-
toEndStream
final Pipeline toEndStream(OutputStream stream)
-
toEndStringBuilder
final Pipeline toEndStringBuilder(StringBuilder stringBuilder)
Ends this Pipeline with stringBuilder
-
-
-
-