class

ReadUntil::ChannelBuffer

Inherits ReadUntil::ReadBuffer < Reference < Object

Constructors

new(capacity : Int32 = 512)
Source

Instance methods

capacity
Source
clear
Source
missed_reads
Source
pop(max : Int32 = 1, order : PopOrder = PopOrder::Newest) : Array(Read)
Source
push(read : Read) : Nil
Source
replaced_chunks
Source
size
Source
wait_for_read(timeout : Time::Span | Nil = nil, stop_signal : Channel(Nil) | Nil = nil) : Bool
Source