Contents

class JPC::Handler
  attr_accessor :token

  def initialize(ws, dispatcher)
    @ws = ws
    @dispatcher = dispatcher
  end

  def ping(params = {})
    "pong #{params}"
  end

  def subscribe(channel)
    @dispatcher.subscribe(@ws, channel)
  end

  def unsubscribe(channel)
    @dispatcher.unsubscribe(@ws, channel)
  end

  private

  def allowed_methods
    procedures + %w(ping subscribe unsubscribe)
  end

  def procedures
    []
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
jpc-1.1.0	lib/jpc/handler.rb