class

Forest::Cell::Reader

Inherits IO::Buffered / IO / Reference / Object

Constructors

new(io : Channel(Frame), flowControl : FlowControl)

Source

Instance methods

Flushes and closes the underlying IO.

Source

closed?

Returns true if this IO is closed.

IO defines returns false, but including types may override.

Source

flowControl

Source

flowControl=(flowControl : FlowControl)

Source

io=(io : Channel(Frame))

Source

mutex

Source

mutex=(mutex : Mutex)

Source

receive

Source

unbuffered_flush

Flushes the wrapped IO.

TODO: Add return type restriction Nil

Source

unbuffered_read(slice : Bytes) : Int32

Reads at most slice.size bytes from the wrapped IO into slice. Returns the number of bytes read.

TODO: Add return type restriction Int32

Source

unbuffered_rewind

Rewinds the wrapped IO.

TODO: Add return type restriction Nil

Source

unbuffered_write(slice : Bytes) : Int64

Writes slice entirely into the wrapped IO.

TODO: Add return type restriction Nil

Source

window_size_increment(stream_identifier : Int32)

Source

windowRemaining

Source

windowRemaining=(windowRemaining : Atomic(Int32))

Source

writer

Source

writer=(value : Writer)

Source

zero_window_remaining?

Source