class Queight::CancellableSubscriber

Public Class Methods

new(channel, subscriber) click to toggle source
# File lib/queight/cancellable_subscriber.rb, line 3
def initialize(channel, subscriber)
  @channel = channel
  @subscriber = subscriber
end

Public Instance Methods

cancel() click to toggle source
# File lib/queight/cancellable_subscriber.rb, line 8
def cancel
  @subscriber.cancel
  @channel.close
end