Sha256: e2046c55953faac0a8eaa0bd8d404b9f7bff76122e2a31fec0e686badf3afe88

Contents?: true

Size: 453 Bytes

Versions: 9

Compression:

Stored size: 453 Bytes

Contents

# frozen_string_literal: true

module Emittance
  ##
  # Base class for event brokers.
  #
  class Broker
    DISPATCHER_KLASS_NAME = 'Dispatcher'

    class << self
      # @param _event [Emittance::Event] the event to be passed off to watchers
      def process_event(_event)
        raise NotImplementedError
      end

      def dispatcher
        const_get DISPATCHER_KLASS_NAME
      end
    end
  end
end

require 'emittance/brokers/synchronous'

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
emittance-2.0.0.pre.1 lib/emittance/broker.rb
emittance-1.1.0 lib/emittance/broker.rb
emittance-1.0.0 lib/emittance/broker.rb
emittance-0.1.3 lib/emittance/broker.rb
emittance-0.1.2 lib/emittance/broker.rb
emittance-0.1.1 lib/emittance/broker.rb
emittance-0.1.0 lib/emittance/broker.rb
emittance-0.0.6 lib/emittance/broker.rb
emittance-0.0.5 lib/emittance/broker.rb