@@ -0,0 +1,356 @@
+package pw.koj.jetstreem.core;%0A%0Aimport java.io.*;%0Aimport java.nio.channels.SelectableChannel;%0A%0Apublic class InputPipeThread extends Thread %7B%0A    private InputStream in;%0A    private SelectableChannel ch;%0A%0A    public InputPipeThread(InputStream in, SelectableChannel ch) %7B%0A        this.in = in;%0A        this.ch = ch;%0A    %7D%0A%0A    public void run() %7B%0A%0A    %7D%0A%7D%0A%0A

add class InputPipeThread