class LavinMQ::Client::Channel::StreamConsumer
Defined in:
lavinmq/client/channel/stream_consumer.crConstructors
Instance Method Summary
- #offset : Int64
- #offset=(offset : Int64)
- #pos : UInt32
- #pos=(pos : UInt32)
- #reject(sp, requeue : Bool)
- #requeued : Deque(LavinMQ::SegmentPosition)
- #segment : UInt32
- #segment=(segment : UInt32)