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