class LavinMQ::AMQP::StreamReader

Defined in:

lavinmq/amqp/stream/stream_reader.cr

Constant Summary

Log = LavinMQ::Log.for("stream_reader")

Constructors

Instance Method Summary

Constructor Detail

def self.new(store : StreamMessageStore, start_offset : String | Int64 | Time) #

[View source]

Instance Method Detail

def each(&) #

[View source]