lib/l2meter/thread_safe.rb in l2meter-0.9.0 vs lib/l2meter/thread_safe.rb in l2meter-0.9.1

- old
+ new

@@ -6,34 +6,29 @@ # make Emitter thread-safe, it makes sure that you don't access the same # instance of emitter from different threads. class ThreadSafe extend Forwardable - EMITTER_METHODS = %i[ - batch - configuration - count - fire! - log - measure - merge! - push_context - sample - silence - silence! - unique - unsilence! - with_elapsed - with_output - ] - - private_constant :EMITTER_METHODS - def initialize(emitter) @emitter = emitter.freeze end - def_delegators :receiver, *EMITTER_METHODS + def_delegators :receiver, \ + :batch, + :configuration, + :count, + :fire!, + :log, + :measure, + :merge!, + :push_context, + :sample, + :silence, + :silence!, + :unique, + :unsilence!, + :with_elapsed, + :with_output def context(*args, &block) value = current_emitter.context(*args, &block) Emitter === value ? clone_with_emitter(value) : value end