lib/karafka/params/params_batch.rb in karafka-1.0.0.rc1 vs lib/karafka/params/params_batch.rb in karafka-1.0.0

- old
+ new

@@ -20,10 +20,10 @@ # @yieldparam [Karafka::Params::Params] each parsed and loaded params instance # @note Invocation of this method will cause loading and parsing each param after another. # If you want to get access without parsing, please access params_batch directly def each - @params_batch.each { |param| yield(param.retrieve) } + @params_batch.each { |param| yield(param.retrieve!) } end # @return [Array<Karafka::Params::Params>] returns all the params in a loaded state, so they # can be used for batch insert, etc. Without invoking all, up until first use, they won't # be parsed