class LavinMQ::AMQP::StreamReader

• LavinMQ::AMQP::StreamReader
• Reference
• Object

Defined in:

lavinmq/amqp/stream/stream_reader.cr

Constant Summary

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

Constructors

• .new(store : StreamMessageStore, start_offset : String | Int64 | Time)

Instance Method Summary

• #each(&)

Constructor Detail

Instance Method Detail