class ReadUntil::Session

• ReadUntil::Session
• Reference
• Object

Defined in:

read_until/session.cr

Constructors

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

Instance Method Summary

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

Constructor Detail

Instance Method Detail