Sha256: 8fc7765642f854340e31408018d030fe791eb44320fbc5982535444f10e1d806

Contents?: true

Size: 427 Bytes

Versions: 25

Compression:

Stored size: 427 Bytes

Contents

module Faye
  class Subscription
    include EventMachine::Deferrable
    
    def initialize(client, channels, callback)
      @client    = client
      @channels  = channels
      @callback  = callback
      @cancelled = false
    end
    
    def cancel
      return if @cancelled
      @client.unsubscribe(@channels, &@callback)
      @cancelled = true
    end
    
    def unsubscribe
      cancel
    end
    
  end
end

Version data entries

25 entries across 25 versions & 3 rubygems

Version Path
faye-0.8.8 lib/faye/protocol/subscription.rb
faye-0.7.2 lib/faye/protocol/subscription.rb
faye-0.6.8 lib/faye/protocol/subscription.rb
faye-0.8.6 lib/faye/protocol/subscription.rb
faye-0.8.5 lib/faye/protocol/subscription.rb
faye-0.8.4 lib/faye/protocol/subscription.rb
faye-0.8.3 lib/faye/protocol/subscription.rb
faye-0.8.2 lib/faye/protocol/subscription.rb
_bushido-faye-0.8.2 lib/faye/protocol/subscription.rb
_bushido-faye-0.8.1 lib/faye/protocol/subscription.rb
bushido-faye-0.8.1 lib/faye/protocol/subscription.rb
faye-0.8.1 lib/faye/protocol/subscription.rb
faye-0.8.0 lib/faye/protocol/subscription.rb
faye-0.7.1 lib/faye/protocol/subscription.rb
faye-0.7.0 lib/faye/protocol/subscription.rb
faye-0.6.7 lib/faye/protocol/subscription.rb
faye-0.6.6 lib/faye/protocol/subscription.rb
faye-0.6.5 lib/faye/protocol/subscription.rb
faye-0.6.4 lib/faye/protocol/subscription.rb
faye-0.6.3 lib/faye/protocol/subscription.rb