Sha256: 90fb1618761ce09ca4a5ea253597d27825932eb464352365a69ae55ddc7df7a5
Contents?: true
Size: 1.4 KB
Versions: 9
Compression:
Stored size: 1.4 KB
Contents
# Toplevel Pubnub module.
module Pubnub
# Pubnub client Class
class Client
# Module that holds generator for all events
module Events
EVENTS = %w[publish subscribe presence leave history here_now audit grant delete_messages
revoke time heartbeat where_now set_state state channel_registration message_counts signal
add_channels_to_push list_push_provisions remove_channels_from_push remove_device_from_push
create_user create_space delete_user delete_space get_user get_users get_space get_spaces
update_user update_space get_members get_space_memberships manage_members manage_memberships].freeze
EVENTS.each do |event_name|
define_method event_name do |options = {}, &block|
options[:callback] = block if options[:callback].nil?
event = Pubnub.const_get(
Formatter.classify_method(event_name)
).new(options, self)
if options[:http_sync]
event.fire
elsif event.is_a? SubscribeEvent
@subscriber.add_subscription(event)
@subscriber.reset
else
Concurrent::Future.execute { event.fire }
end
end
end
alias unsubscribe leave
alias get_state state
def fire(options, &block)
publish(options.merge(store: false, replicate: false), &block)
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems