in lib/logstash-docket/util/threadsafe_index.rb [45:52]
def each return enum_for(:each) unless block_given? @mutex.synchronize { @index.to_a }.each do |key, value| yield key, value end end