class

ReadUntil::Session

Inherits Reference < Object

Constructors

new(connection : Minknow::Connection, config : Config, buffer : ReadBuffer, registry : ClassificationRegistry = ClassificationRegistry.default, signal_format : SignalFormat = SignalFormat.new)
Source

Instance methods

buffer
Source
close
Source
config
Source
each_read(batch_size : Int32 = 1, order : PopOrder = PopOrder::Newest, timeout : Time::Span | Nil = nil, & : Read -> Nil) : Nil
Source
next_read?(timeout : Time::Span | Nil = nil) : Read | Nil
Source
one_chunk?
Source
pop_reads(max : Int32 = 1, order : PopOrder = PopOrder::Newest) : Array(Read)
Source
progress
Source
reconfigure(*, channels : Range(Int32, Int32) | Nil = nil, raw_data : RawDataKind | Nil = nil, min_chunk_size : UInt64 | Nil = nil, prefilter : Prefilter | Nil = nil) : Nil
Source
running?
Source
start
Source
stats
Source
stop(read : Read | ReadRef) : ActionToken
Source
stop
Source
unblock(read : Read | ReadRef, for duration : Time::Span = config.unblock_duration) : ActionToken
Source