Contents

module Wisper
  class TemporaryListeners

    def self.with(*listeners, &block)
      options = listeners.last.is_a?(Hash) ? listeners.pop : {}
      new.with(listeners, options, &block)
    end

    def self.registrations
      new.registrations
    end

    def with(listeners, options, &block)
      add_listeners(listeners, options)
      yield
      clear
    end

    def registrations
      Thread.current[key] ||= Set.new
    end

    private

    def clear
      registrations.clear
    end

    def add_listeners(listeners, options)
      listeners.each { |listener| add_listener(listener, options)}
    end

    def add_listener(listener, options)
      registrations << ObjectRegistration.new(listener, options)
    end

    def key
      '__wisper_temporary_listeners'
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
wisper-1.3.0	lib/wisper/temporary_listeners.rb
wisper-1.2.1	lib/wisper/temporary_listeners.rb
wisper-1.2.0	lib/wisper/temporary_listeners.rb
wisper-1.1.0	lib/wisper/temporary_listeners.rb