Sha256: b58ea50315236b9706c2c00542a6350c3cc0d3d823636f4b7da4fd696df46ecb
Contents?: true
Size: 1.45 KB
Versions: 3
Compression:
Stored size: 1.45 KB
Contents
module Wisper class ObjectRegistration < Registration attr_reader :with, :prefix, :allowed_classes, :broadcaster def initialize(listener, options) super(listener, options) @with = options[:with] @prefix = stringify_prefix(options[:prefix]) @allowed_classes = Array(options[:scope]).map(&:to_s).to_set @broadcaster = map_broadcaster(options[:async] || options[:broadcaster]) end def broadcast(event, publisher, *args) method_to_call = map_event_to_method(event) if should_broadcast?(event) && listener.respond_to?(method_to_call) && publisher_in_scope?(publisher) broadcaster.broadcast(listener, publisher, method_to_call, args) end end private def publisher_in_scope?(publisher) allowed_classes.empty? || publisher.class.ancestors.any? { |ancestor| allowed_classes.include?(ancestor.to_s) } end def map_event_to_method(event) prefix + (with || event).to_s end def stringify_prefix(_prefix) case _prefix when nil '' when true default_prefix + '_' else _prefix.to_s + '_' end end def default_prefix 'on' end def map_broadcaster(value) return value if value.respond_to?(:broadcast) value = :async if value == true value = :default if value == nil configuration.broadcasters.fetch(value) end def configuration Wisper.configuration end end end
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
wisper-1.6.1 | lib/wisper/registration/object.rb |
wisper-1.6.0 | lib/wisper/registration/object.rb |
wisper-1.5.0 | lib/wisper/registration/object.rb |