Sha256: 007a5435545df23cf6bf333fb2ec6f95d9126a731db8420376d60af11745fc5d

Contents?: true

Size: 473 Bytes

Versions: 4

Compression:

Stored size: 473 Bytes

Contents

module Resugan
  module Engine
    class MarshalledInlineDispatcher
      def dispatch(namespace, events)
        marshalled_events = []
        events.each do |k, v|
          marshalled_events << { event: k, args: v }.to_json
        end

        marshalled_events.each do |event|
          unmarshalled_event = JSON.parse(event)
          Resugan::Kernel.invoke(namespace, unmarshalled_event['event'], unmarshalled_event['args'])
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
resugan-0.1.15 lib/resugan/engine/marshalled_inline_dispatcher.rb
resugan-0.1.14 lib/resugan/engine/marshalled_inline_dispatcher.rb
resugan-0.1.13 lib/resugan/engine/marshalled_inline_dispatcher.rb
resugan-0.1.12 lib/resugan/engine/marshalled_inline_dispatcher.rb