Class: Kafka::PendingMessageQueue
- Inherits:
-
Object
- Object
- Kafka::PendingMessageQueue
- Defined in:
- lib/kafka/pending_message_queue.rb
Instance Attribute Summary collapse
-
#bytesize ⇒ Object
readonly
Returns the value of attribute bytesize.
-
#size ⇒ Object
readonly
Returns the value of attribute size.
Instance Method Summary collapse
- #clear ⇒ Object
-
#each {|message| ... } ⇒ nil
Yields each message in the queue.
- #empty? ⇒ Boolean
-
#initialize ⇒ PendingMessageQueue
constructor
A new instance of PendingMessageQueue.
- #replace(messages) ⇒ Object
- #write(message) ⇒ Object
Constructor Details
#initialize ⇒ PendingMessageQueue
Returns a new instance of PendingMessageQueue.
6 7 8 |
# File 'lib/kafka/pending_message_queue.rb', line 6 def initialize clear end |
Instance Attribute Details
#bytesize ⇒ Object (readonly)
Returns the value of attribute bytesize.
4 5 6 |
# File 'lib/kafka/pending_message_queue.rb', line 4 def bytesize @bytesize end |
#size ⇒ Object (readonly)
Returns the value of attribute size.
4 5 6 |
# File 'lib/kafka/pending_message_queue.rb', line 4 def size @size end |
Instance Method Details
#clear ⇒ Object
20 21 22 23 24 |
# File 'lib/kafka/pending_message_queue.rb', line 20 def clear @messages = [] @size = 0 @bytesize = 0 end |
#each {|message| ... } ⇒ nil
Yields each message in the queue.
35 36 37 |
# File 'lib/kafka/pending_message_queue.rb', line 35 def each(&block) @messages.each(&block) end |
#empty? ⇒ Boolean
16 17 18 |
# File 'lib/kafka/pending_message_queue.rb', line 16 def empty? @messages.empty? end |
#replace(messages) ⇒ Object
26 27 28 29 |
# File 'lib/kafka/pending_message_queue.rb', line 26 def replace() clear .each {|| write() } end |
#write(message) ⇒ Object
10 11 12 13 14 |
# File 'lib/kafka/pending_message_queue.rb', line 10 def write() @messages << @size += 1 @bytesize += .bytesize end |