Rx-java2 wrapper for subprocess execution - Support java.lang.Process and com.zaxxer.nuprocess.NuProcess.
Add dependency:
<dependency>
<groupId>com.github.zella</groupId>
<artifactId>rx-process2</artifactId>
<version>0.2.0-BETA2</version>
</dependency>
Build process:
ProcessBuilder jBuilder = ...; //or NuProcessBuilder, NuProcess
IReactiveProcessBuilder<Process> builder = RxProcess.reactive(jBuilder);
Here multiple variants of process execution:
Observable<ProcessChunk> stdOutErr = builder.asStdErrOut();
Observable<byte[]> stdout = builder.asStdOut();
Single<byte[]> stdoutSingle = builder.asStdOutSingle();
Single<Exit> waitExit = builder.asWaitDone();
//suports stdin as single portion of bytes
builder.withStdin("hello worlds".getBytes())
Bidirectional communication
IReactiveProcess<Process> bi = builder.biDirectional();
Single<Process> started = bi.started();
Subscriber<byte[]> stdin = bi.stdIn();
Observable<byte[]> stdoutBi = bi.stdOut();
Observable<ProcessChunk> stdoutErrBi = bi.stdOutErr();
//Cold subscription, start the process
Single<Exit> waitExitBi = bi.waitDone();
//write to stdin
stdin.onNext("hello".getBytes());