class
ReadUntil::Client
- ReadUntil::Client
- Reference
- Object
Defined in:
read_until/client.crConstructors
Instance Method Summary
- #classifications : ClassificationRegistry
- #connection : Minknow::Connection
- #endpoint : String
- #new_session(config : Config, buffer : ReadBuffer = ChannelBuffer.new(capacity: 512)) : Session
- #new_session(*, channels : Range(Int32, Int32) = 1..512, raw_data : RawDataKind = RawDataKind::Calibrated, min_chunk_size : UInt64 = 0_u64, mode : StreamMode = StreamMode::OneChunk, prefilter : Prefilter = Prefilter.none, buffer : ReadBuffer = ChannelBuffer.new(capacity: 512), action_batch_size : Int32 = 1000, action_throttle : Time::Span = 1.millisecond, unblock_duration : Time::Span = 100.milliseconds) : Session
- #open(config : Config, buffer : ReadBuffer = ChannelBuffer.new(capacity: 512), & : Session -> Nil) : Nil
- #open(*, channels : Range(Int32, Int32) = 1..512, raw_data : RawDataKind = RawDataKind::Calibrated, min_chunk_size : UInt64 = 0_u64, mode : StreamMode = StreamMode::OneChunk, prefilter : Prefilter = Prefilter.none, buffer : ReadBuffer = ChannelBuffer.new(capacity: 512), action_batch_size : Int32 = 1000, action_throttle : Time::Span = 1.millisecond, unblock_duration : Time::Span = 100.milliseconds, & : Session -> Nil) : Nil
- #signal_format : SignalFormat
Constructor Detail
def self.new(connection : Minknow::Connection, classifications : ClassificationRegistry = ClassificationRegistry.default)
#
Instance Method Detail
def new_session(config : Config, buffer : ReadBuffer = ChannelBuffer.new(capacity: 512)) : Session
#
def new_session(*, channels : Range(Int32, Int32) = 1..512, raw_data : RawDataKind = RawDataKind::Calibrated, min_chunk_size : UInt64 = 0_u64, mode : StreamMode = StreamMode::OneChunk, prefilter : Prefilter = Prefilter.none, buffer : ReadBuffer = ChannelBuffer.new(capacity: 512), action_batch_size : Int32 = 1000, action_throttle : Time::Span = 1.millisecond, unblock_duration : Time::Span = 100.milliseconds) : Session
#
def open(config : Config, buffer : ReadBuffer = ChannelBuffer.new(capacity: 512), & : Session -> Nil) : Nil
#
def open(*, channels : Range(Int32, Int32) = 1..512, raw_data : RawDataKind = RawDataKind::Calibrated, min_chunk_size : UInt64 = 0_u64, mode : StreamMode = StreamMode::OneChunk, prefilter : Prefilter = Prefilter.none, buffer : ReadBuffer = ChannelBuffer.new(capacity: 512), action_batch_size : Int32 = 1000, action_throttle : Time::Span = 1.millisecond, unblock_duration : Time::Span = 100.milliseconds, & : Session -> Nil) : Nil
#