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
    }
}


package pw.koj.jetstreem.core;

public class StrmReadIO extends Streem {
    private ChannelReadBuffer crbuf;

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

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

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


change member type from ByteBuffer to ChannelReadBuffer in StrmReadIO