class DDP::Server::WebSocket
Server
on top of a Celluloid::WebSocket
Attributes
api[RW]
subscriptions[RW]
Public Class Methods
new(api_class, *args)
click to toggle source
# File lib/ddp/server.rb, line 15 def initialize(api_class, *args) @api = api_class.new(*args) @subscriptions = {} end
Public Instance Methods
on_open()
click to toggle source
# File lib/ddp/server.rb, line 20 def on_open handle_connect end
read_message()
click to toggle source
# File lib/ddp/server.rb, line 24 def read_message EJSON.parse read end
write_message(message)
click to toggle source
# File lib/ddp/server.rb, line 28 def write_message(message) write EJSON.generate(message) end