@@ -0,0 +1,948 @@
+package pw.koj.jetstreem.core;%0A%0Aimport java.nio.channels.WritableByteChannel;%0Aimport java.io.DataOutputStream;%0Aimport java.io.IOException;%0A%0Apublic class StrmWriteIO extends Streem %7B%0A    private DataOutputStream outStream;%0A%0A    public StrmWriteIO(StrmQueue queue, DataOutputStream outStream) %7B%0A        super(TaskMode.CONS, queue, StrmWriteIO::writeCb, StrmWriteIO::writeClose, null);%0A        this.outStream = outStream;%0A    %7D%0A%0A    public DataOutputStream outStream() %7B%0A        return this.outStream;%0A    %7D%0A%0A    public static void writeCb(Streem strm, Object data) %7B%0A        StrmWriteIO ioStrm = (StrmWriteIO)strm;%0A        DataOutputStream out = ioStrm.outStream();%0A        String str = (String)data;%0A%0A        try %7B%0A            out.writeUTF(str);%0A        %7D catch (IOException ex) %7B%0A            System.err.println(%22I/O error: %22 + ex.getMessage());%0A        %7D%0A    %7D%0A%0A    public static void writeClose(Streem strm, Object data) %7B%0A        // TBD%0A    %7D%0A%0A%7D%0A

add class StrmWriteIO