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