JarCastingPipe any streams, socket, process, ...
Stream Pipes
// create a pipe
Pipe pipe = Pipes.create("optional pipe name", myInputStream, myOutputStream).listenedBy(myOptionalPipeListener);
// get the connection handle
PipeConnection connection = pipe.connect();
// then you can do
connection.await();
connection.await(1, SECONDS);
connection.interrupt();
Process Pipes
ProcessPipe pipe = Pipes.pipe(
new ProcessBuilder("ls", "-al", "/workspace/ovea/project/pipe/src").start(),
new ProcessBuilder("cut", "-c", "50-").start(),
new ProcessBuilder("grep", "-v", "-E", "\"^\\.\\.?$\"").start());
Pipes.connect("out", pipe.getInputStream(), System.out);
Pipes.connect("err", pipe.getErrorStream(), System.err);
int retCode = pipe.waitFor();
Socket Tunnels
Socket socket1 = new Socket("localhost", 2000);
Socket socket2 = new Socket("localhost", 2222);
Tunnel tunnel = Tunnel.connect(socket1, socket2, new TunnelListener() {
@Override
public void onConnect(Tunnel tunnel) {
System.out.println("onConnect - " + tunnel);
}
@Override
public void onClose(Tunnel tunnel) {
System.out.println("onClose - " + tunnel);
}
@Override
public void onBroken(Tunnel tunnel, BrokenTunnelException e) {
System.out.println("onBroken - " + tunnel);
}
@Override
public void onInterrupt(Tunnel tunnel) {
System.out.println("onInterrupt - " + tunnel);
}
});
