class IO::Stream::Generic
def initialize(block_size: BLOCK_SIZE, maximum_read_size: MAXIMUM_READ_SIZE)
def initialize(block_size: BLOCK_SIZE, maximum_read_size: MAXIMUM_READ_SIZE) @eof = false @writing = ::Thread::Mutex.new @block_size = block_size @maximum_read_size = maximum_read_size @read_buffer = StringBuffer.new @write_buffer = StringBuffer.new # Used as destination buffer for underlying reads. @input_buffer = StringBuffer.new end