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