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

3 entries across 3 versions & 2 rubygems

Version	Path
faye-0.8.11	lib/faye/protocol/subscription.rb
face-faye-0.8.9	lib/faye/protocol/subscription.rb
faye-0.8.9	lib/faye/protocol/subscription.rb