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