Sha256: 9747407186ba15665865ccfb035a8b130b70936a9fda6a0614fd73df8d6ad636
Contents?: true
Size: 729 Bytes
Versions: 16
Compression:
Stored size: 729 Bytes
Contents
module Startback module Websocket module Hub class Message def initialize(data, socket) data = JSON.parse(data, symbolize_names: true) @headers = data[:headers] || {} @body = data[:body] || {} @socket = socket end attr_reader :headers, :body, :socket def reply(message) raise "No reply-to header found" unless headers[:'reply-to'] response = { headers: { :'in-reply-to' => headers[:'reply-to'] }, body: message } @socket.send(response.to_json) end end # class Message end # module Hub end # module Websocket end # module Startback
Version data entries
16 entries across 16 versions & 1 rubygems