Class: Shydra::Hydra

Inherits:

Typhoeus::Hydra

• Object
• Typhoeus::Hydra
• Shydra::Hydra

Defined in:

lib/shydra/hydra.rb

Instance Method Summary

• #dequeue ⇒ Object
• #initialize(options = {}) ⇒ Hydra constructor

  A new instance of Hydra.

• #pause! ⇒ Object
• #paused? ⇒ Boolean
• #run ⇒ Object

Constructor Details

#initialize(options = {}) ⇒ Hydra

# File 'lib/shydra/hydra.rb', line 36

def initialize(options = {})
  options[:max_concurrency] ||= Shydra.max_concurrency
  super(options)
end

Instance Method Details

#dequeue ⇒ Object

# File 'lib/shydra/hydra.rb', line 56

def dequeue
  return if paused?
  super
end

#pause! ⇒ Object

# File 'lib/shydra/hydra.rb', line 43

def pause!
  @paused = true
end

#paused? ⇒ Boolean

# File 'lib/shydra/hydra.rb', line 47

def paused?
  @paused
end

#run ⇒ Object

# File 'lib/shydra/hydra.rb', line 51

def run
  @paused = false
  super
end