module Roda::RodaPlugins::MessageBus::RequestMethods

Public Instance Methods

message_bus(channels=nil) { || ... } click to toggle source
   # File lib/roda/plugins/message_bus.rb
58 def message_bus(channels=nil)
59   if remaining_path =~ /\A\/message-bus\//
60     chans = env['message_bus.channels'] = {}
61     post = self.POST
62     channels ||= script_name + path_info.chomp(remaining_path)
63     Array(channels).each do |channel|
64       if val = post[channel]
65         chans[channel] = val
66       end
67     end
68     env['message_bus.seq'] = post['__seq']
69     yield if block_given?
70     run roda_class.message_bus_app
71   end
72 end