module TubeHelper

Attributes

tube_name[RW]

Public Class Methods

extended(klass) click to toggle source
# File lib/beanstalk-client-rspec/matchers.rb, line 5
def self.extended(klass)
  klass.instance_eval do
    chain :for do |tube_name|
      self.tube_name = tube_name
    end
  end
end

Private Instance Methods

tube_size(beanstalk) click to toggle source
# File lib/beanstalk-client-rspec/matchers.rb, line 25
def tube_size(beanstalk)
  states = tubes(beanstalk)[tube_name] || {}
  (states['ready'] || []).size
end
tubes(beanstalk) click to toggle source
# File lib/beanstalk-client-rspec/matchers.rb, line 17
def tubes(beanstalk)
  beanstalk.instance_variable_get(:@connections)['default'].instance_variable_get(:@tubes)
end