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