Sha256: 560fed23e5f071e56f9b62467bcc5965f3c037ef7c099ccf014ef47416bf96f7
Contents?: true
Size: 735 Bytes
Versions: 16
Compression:
Stored size: 735 Bytes
Contents
module Startback
module Websocket
module Hub
module Middleware
class CommandHandler
def initialize(app, opts, &bl)
@app = app
@opts = opts
@handler = bl
end
def call(event, socket, env)
who = matches?(event) ? @handler : @app
who.call(event, socket, env)
end
private
def matches?(event)
if event.headers[:command]
event.headers[:command]&.to_sym === @opts[:name]
else
false
end
end
end # class CommandHandler
end # module Middleware
end # module Hub
end # module Websocket
end # module Startback
Version data entries
16 entries across 16 versions & 1 rubygems