Method: Kafka::PendingMessageQueue#each

Defined in:: lib/kafka/pending_message_queue.rb

#each {|message| ... } ⇒ `nil`

Yields each message in the queue.

Yield Parameters:

message (PendingMessage)

Returns:

(nil)



37
38
39

# File 'lib/kafka/pending_message_queue.rb', line 37

def each(&block)
  @messages.each(&block)
end