class ProcessPipeline extends ProcessLike
- Self Type
- ProcessPipeline
- Alphabetic
- By Inheritance
- ProcessPipeline
- ProcessLike
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new ProcessPipeline(processes: Seq[SubProcess], pipefail: Boolean, brokenPipeQueue: Option[LinkedBlockingQueue[Int]])
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def close(): Unit
Alias for destroy, implemented for java.lang.AutoCloseable.
Alias for destroy, implemented for java.lang.AutoCloseable.
- Definition Classes
- ProcessPipeline → ProcessLike → AutoCloseable
- def commandString: String
String representation of the pipeline.
- def destroy(): Unit
Attempt to destroy the ProcessPipeline (gently), via the underlying JVM APIs.
Attempt to destroy the ProcessPipeline (gently), via the underlying JVM APIs. All processes in the pipeline are destroyed.
- Definition Classes
- ProcessPipeline → ProcessLike
- def destroyForcibly(): Unit
Force-destroys the ProcessPipeline, via the underlying JVM APIs.
Force-destroys the ProcessPipeline, via the underlying JVM APIs. All processes in the pipeline are force-destroyed.
- Definition Classes
- ProcessPipeline → ProcessLike
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def exitCode(): Int
The exit code of this ProcessPipeline.
The exit code of this ProcessPipeline. Conventionally, 0 exit code represents a successful termination, and non-zero exit code indicates a failure. Throws an exception if the subprocess has not terminated.
If pipefail is set, the exit code is the first non-zero exit code of the pipeline. If no process in the pipeline has a non-zero exit code, the exit code is 0.
- Definition Classes
- ProcessPipeline → ProcessLike
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def isAlive(): Boolean
Returns
trueif the ProcessPipeline is still running and has not terminated.Returns
trueif the ProcessPipeline is still running and has not terminated. Any process in the pipeline can be alive for the pipeline to be alive.- Definition Classes
- ProcessPipeline → ProcessLike
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def join(timeout: Long = -1): Boolean
Wait up to
millisfor the ProcessPipeline to terminate all the processes in pipeline.Wait up to
millisfor the ProcessPipeline to terminate all the processes in pipeline. By default waits indefinitely; if a time limit is given, explicitly destroys each process if it has not completed by the time the timeout has occurred.- Definition Classes
- ProcessPipeline → ProcessLike
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val processes: Seq[SubProcess]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def waitFor(timeout: Long = -1): Boolean
Wait up to
millisfor the ProcessPipeline to terminate, by default waits indefinitely.Wait up to
millisfor the ProcessPipeline to terminate, by default waits indefinitely. Returnstrueif the ProcessPipeline has terminated by the time this method returns.Waits for each process one by one, while aggregating the total time waited. If timeout has passed before all processes have terminated, returns
false.- Definition Classes
- ProcessPipeline → ProcessLike