com.github.zella.rxprocess2

Class RxNuProcessBuilder

java.lang.Object

com.github.zella.rxprocess2.RxNuProcessBuilder

public class RxNuProcessBuilder
extends java.lang.Object

Builder for constructing process

Method Summary

Modifier and Type	Method and Description
PreparedStreams	asStdInOut() Represent process as all possible control flows, more @see PreparedStreams
io.reactivex.Observable<byte[]>	asStdOut() Same as asStdOut, with default timeout.
io.reactivex.Observable<byte[]>	asStdOut(long timeout, java.util.concurrent.TimeUnit timeUnit) Represent process as single cold stream, where, onCompleted signals correct process exit, onError - exit with non zero code, timeout or any others errors.
io.reactivex.Single<byte[]>	asStdOutSingle() Same as asStdOutSingle, with default timeout.
io.reactivex.Single<byte[]>	asStdOutSingle(long timeout, java.util.concurrent.TimeUnit timeUnit) Same as asStdOut, but buffered
io.reactivex.Single<Exit>	asWaitDone() Same as waitDone with default timeout.
io.reactivex.Single<Exit>	asWaitDone(long timeout, java.util.concurrent.TimeUnit timeUnit) Represent process as single "done" callback
static RxNuProcessBuilder	fromCommand(java.util.List<java.lang.String> command) Create new builder with command
RxNuProcessBuilder	withCwd(java.nio.file.Path cwd) Set working directory
RxNuProcessBuilder	withEnv(java.util.Map<java.lang.String,java.lang.String> environment) Set environment variables

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

withEnv

public RxNuProcessBuilder withEnv(java.util.Map<java.lang.String,java.lang.String> environment)

Set environment variables

Parameters:

environment - vars

Returns:

builder

withCwd

public RxNuProcessBuilder withCwd(java.nio.file.Path cwd)

Set working directory

Parameters:

cwd - workdir

Returns:

asStdOut

public io.reactivex.Observable<byte[]> asStdOut(long timeout,
                                                java.util.concurrent.TimeUnit timeUnit)

Represent process as single cold stream, where, onCompleted signals correct process exit, onError - exit with non zero code, timeout or any others errors. Canceling force kills process. Note, that base class for error @see ProcessException

Parameters:

timeout - process timeout

timeUnit - process timeout units

Returns:

stdout observable

asStdOut

public io.reactivex.Observable<byte[]> asStdOut()

Same as asStdOut, with default timeout. Default timeout - 60 sec, can be set via rxprocess2.defaultTimeoutMillis property

Returns:

stdout observable

asStdOutSingle

public io.reactivex.Single<byte[]> asStdOutSingle(long timeout,
                                                  java.util.concurrent.TimeUnit timeUnit)

Same as asStdOut, but buffered

Parameters:

timeout - process timeout

timeUnit - process timeout units

Returns:

stdout single

asStdOutSingle

public io.reactivex.Single<byte[]> asStdOutSingle()

Same as asStdOutSingle, with default timeout. Default timeout - 60 sec, can be set via rxprocess2.defaultTimeoutMillis property

Returns:

stdout single

asStdInOut

public PreparedStreams asStdInOut()

Represent process as all possible control flows, more @see PreparedStreams

Returns:

stream container

asWaitDone

public io.reactivex.Single<Exit> asWaitDone(long timeout,
                                            java.util.concurrent.TimeUnit timeUnit)

Represent process as single "done" callback

Parameters:

timeout - process timeout

timeUnit - process timeout units

Returns:

single contained process exit code with optional failure

asWaitDone

public io.reactivex.Single<Exit> asWaitDone()

Same as waitDone with default timeout. Default timeout - 60 sec, can be set via rxprocess2.defaultTimeoutMillis property

Returns:

single contained process exit code with optional failure

fromCommand

public static RxNuProcessBuilder fromCommand(java.util.List<java.lang.String> command)

Create new builder with command

Parameters:

command - command

Returns:

new builder