class

LavinMQ::AMQP::StreamReader

Inherits Reference < Object

Constants

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

Constructors

new(stream : Stream, start_offset : String | Int64 | Time)
Source

Instance methods

each
Source