Sha256: e9eced00591178fac675fa5d02da7cb9526dddf5ec34349ad50a54b3c5918e93
Contents?: true
Size: 510 Bytes
Versions: 29
Compression:
Stored size: 510 Bytes
Contents
# Toplevel Pubnub module.
module Pubnub
# Holds subscribe functionality, beware, most of subscribe functionality is
# held by SubscribeEvent
class Subscribe < SubscribeEvent
include Concurrent::Async
include Pubnub::Validator::Subscribe
def initialize(options, app)
@event = :subscribe
super
app.apply_state(self)
end
def clear_state
@state = nil
end
private
def current_operation
Pubnub::Constants::OPERATION_SUBSCRIBE
end
end
end
Version data entries
29 entries across 29 versions & 1 rubygems