package pw.koj.jetstreem.core;
import java.nio.ByteBuffer;

public class StrmReadIO extends Streem {
    private ByteBuffer buf;

    public StrmReadIO(StrmQueue queue, ByteBuffer buf) {
        super(TaskMode.PROD, queue, StrmReadIO::stdioRead, StrmReadIO::readClose, null);
        this.buf = buf;
    }

    private static void stdioRead(Streem strm, Void data) {
        // TBD
    }

    private static void readClose(Streem strm, Void data) {
        // TBD
    }
}


@@ -27,36 +27,8 @@
 ore;
-%0Aimport java.nio.ByteBuffer;
 %0A%0Apu
@@ -78,27 +78,36 @@
 private 
-Byte
+ChannelRead
 Buffer 
+cr
 buf;%0A%0A  
@@ -147,19 +147,28 @@
 ue, 
-Byte
+ChannelRead
 Buffer 
+cr
 buf)
@@ -276,14 +276,18 @@
 his.
+cr
 buf = 
+cr
 buf;

change member type from ByteBuffer to ChannelReadBuffer in StrmReadIO