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