-
- All Implemented Interfaces:
-
eu.jrie.jetbrains.kotlinshell.processes.execution.ExecutionContext,eu.jrie.jetbrains.kotlinshell.processes.execution.ProcessExecutionContext,eu.jrie.jetbrains.kotlinshell.shell.ShellBase,eu.jrie.jetbrains.kotlinshell.shell.ShellUtility
@ExperimentalCoroutinesApi() public interface ShellPiping implements ShellUtility
-
-
Method Summary
Modifier and Type Method Description abstract Pipelinepipeline(ExecutionMode mode, SuspendFunction1<AbstractPipingDSLShell, Pipeline> pipelineConfig)Creates and executes new Pipeline specified by DSL pipelineConfig and executes it in given mode Part of piping DSL abstract Pipelinedetach(SuspendFunction1<AbstractPipingDSLShell, Pipeline> pipelineConfig)Creates new Pipeline specified by DSL pipelineConfig and executes it as detached job. abstract Unitfg(Pipeline pipeline)Attaches selected Pipeline SuspendFunction1<ExecutionContext, Unit>contextLambda(SuspendFunction1<ExecutionContext, Unit> lambda)Constructs PipelineContextLambda to be used in piping Part of piping DSL SuspendFunction1<ExecutionContext, Unit>packetLambda(SuspendFunction1<ByteReadPacket, Pair<ByteReadPacket, ByteReadPacket>> lambda)Constructs PipelinePacketLambda to be used in piping Part of piping DSL ByteReadPacketpacket(ByteArray bytes)Constructs ByteReadPacket from given bytes Part of piping DSL ByteReadPacketpacket(String string)Constructs ByteReadPacket from given string Part of piping DSL ByteReadPacketemptyPacket()Constructs empty ByteReadPacket Part of piping DSL SuspendFunction1<ExecutionContext, Unit>byteArrayLambda(SuspendFunction1<ByteArray, Pair<ByteArray, ByteArray>> lambda)Constructs PipelineByteArrayLambda to be used in piping Part of piping DS ByteArrayemptyByteArray()SuspendFunction1<ExecutionContext, Unit>stringLambda(SuspendFunction1<String, Pair<String, String>> lambda)Constructs PipelineStringLambda to be used in piping Part of piping DSL SuspendFunction1<ExecutionContext, Unit>streamLambda(SuspendFunction3<InputStream, OutputStream, OutputStream, Unit> lambda)Constructs PipelineStreamLambda to be used in piping Part of piping DSL abstract List<Pair<Integer, Pipeline>>getDetachedPipelines()List of detached pipelines SuspendFunction1<ExecutionContext, Unit>getEnv()SuspendFunction1<ExecutionContext, Unit>getSet()Map<String, String>getShellEnv()Map<String, String>getSystemEnv()abstract CoroutineScopegetScope()CoroutineScope used by this shell, its members and sub shells abstract Map<String, String>getEnvironment()Environment of this shell. abstract Map<String, String>getVariables()Variables of this shell. abstract FilegetDirectory()Current directory of this shell abstract ProcessCommandergetCommander()abstract ReceiveChannel<ByteReadPacket>getStdin()abstract SendChannel<ByteReadPacket>getStdout()abstract SendChannel<ByteReadPacket>getStderr()-
Methods inherited from class eu.jrie.jetbrains.kotlinshell.shell.piping.ShellPiping
cd, cd, cd, cd, cd, env, export, export, file, file, mkdir, unset, variable, variable -
Methods inherited from class eu.jrie.jetbrains.kotlinshell.shell.ShellUtility
closeOut, command, finalize, invoke -
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Method Detail
-
pipeline
abstract Pipeline pipeline(ExecutionMode mode, SuspendFunction1<AbstractPipingDSLShell, Pipeline> pipelineConfig)
Creates and executes new Pipeline specified by DSL pipelineConfig and executes it in given mode Part of piping DSL
-
detach
abstract Pipeline detach(SuspendFunction1<AbstractPipingDSLShell, Pipeline> pipelineConfig)
Creates new Pipeline specified by DSL pipelineConfig and executes it as detached job. Part of piping DSL
-
contextLambda
SuspendFunction1<ExecutionContext, Unit> contextLambda(SuspendFunction1<ExecutionContext, Unit> lambda)
Constructs PipelineContextLambda to be used in piping Part of piping DSL
-
packetLambda
SuspendFunction1<ExecutionContext, Unit> packetLambda(SuspendFunction1<ByteReadPacket, Pair<ByteReadPacket, ByteReadPacket>> lambda)
Constructs PipelinePacketLambda to be used in piping Part of piping DSL
-
packet
ByteReadPacket packet(ByteArray bytes)
Constructs ByteReadPacket from given bytes Part of piping DSL
-
packet
ByteReadPacket packet(String string)
Constructs ByteReadPacket from given string Part of piping DSL
-
emptyPacket
ByteReadPacket emptyPacket()
Constructs empty ByteReadPacket Part of piping DSL
-
byteArrayLambda
SuspendFunction1<ExecutionContext, Unit> byteArrayLambda(SuspendFunction1<ByteArray, Pair<ByteArray, ByteArray>> lambda)
Constructs PipelineByteArrayLambda to be used in piping Part of piping DS
-
emptyByteArray
ByteArray emptyByteArray()
-
stringLambda
SuspendFunction1<ExecutionContext, Unit> stringLambda(SuspendFunction1<String, Pair<String, String>> lambda)
Constructs PipelineStringLambda to be used in piping Part of piping DSL
-
streamLambda
SuspendFunction1<ExecutionContext, Unit> streamLambda(SuspendFunction3<InputStream, OutputStream, OutputStream, Unit> lambda)
Constructs PipelineStreamLambda to be used in piping Part of piping DSL
-
getDetachedPipelines
abstract List<Pair<Integer, Pipeline>> getDetachedPipelines()
List of detached pipelines
-
getEnv
SuspendFunction1<ExecutionContext, Unit> getEnv()
-
getSet
SuspendFunction1<ExecutionContext, Unit> getSet()
-
getShellEnv
Map<String, String> getShellEnv()
-
getSystemEnv
Map<String, String> getSystemEnv()
-
getScope
abstract CoroutineScope getScope()
CoroutineScope used by this shell, its members and sub shells
-
getEnvironment
abstract Map<String, String> getEnvironment()
Environment of this shell. These variables are being inherited to sub shells.
-
getVariables
abstract Map<String, String> getVariables()
Variables of this shell. These variables are not being inherited to sub shells.
-
getDirectory
abstract File getDirectory()
Current directory of this shell
-
getCommander
abstract ProcessCommander getCommander()
-
getStdin
abstract ReceiveChannel<ByteReadPacket> getStdin()
-
getStdout
abstract SendChannel<ByteReadPacket> getStdout()
-
getStderr
abstract SendChannel<ByteReadPacket> getStderr()
-
-
-
-