@@ -0,0 +1,779 @@
+package pw.koj.jetstreem.core;%0A%0Apublic class Main %7B%0A    public static void main(String%5B%5D args) %7B%0A        StrmQueue queue = StrmQueue.getInstance();%0A        StrmIOLoop ioLoop = StrmIOLoop.getInstance();%0A%0A        ChannelReadBuffer stdinBuf = new ChannelReadBuffer(new InputPipeThread(System.in));%0A%0A        Streem strmStdin = new StrmReadIO(queue, stdinBuf, ioLoop);%0A        Streem strmMap = new StrmFuncMap(queue, Main::strmToUpper);%0A        Streem strmStdout = new StrmWriteIO(queue, System.out);%0A%0A        strmStdin.connect(strmMap);%0A        strmMap.connect(strmStdout);%0A%0A        ioLoop.start();%0A        queue.loop();%0A    %7D%0A%0A    public static Object strmToUpper(Streem strm, Object data) %7B%0A        String str = new String((char%5B%5D)data);%0A        return str.toUpperCase();%0A    %7D%0A%7D%0A%0A

add class Main