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