module Pakyow::Application::Helpers::Realtime::Subscriptions

Public Instance Methods

subscribe(channel, *qualifiers) click to toggle source
# File lib/pakyow/application/helpers/realtime/subscriptions.rb, line 10
def subscribe(channel, *qualifiers)
  channels = if qualifiers.empty?
    Pakyow::Realtime::Channel.new(channel)
  else
    qualifiers.map { |qualifier|
      Pakyow::Realtime::Channel.new(channel, qualifier)
    }
  end

  app.websocket_server.socket_subscribe(socket_client_id, *channels)
end
unsubscribe(channel, *qualifiers) click to toggle source
# File lib/pakyow/application/helpers/realtime/subscriptions.rb, line 22
def unsubscribe(channel, *qualifiers)
  channels = if qualifiers.empty?
    Pakyow::Realtime::Channel.new(channel, "*")
  else
    qualifiers.map { |qualifier|
      Pakyow::Realtime::Channel.new(channel, qualifier)
    }
  end

  app.websocket_server.socket_unsubscribe(*channels)
end