class GHTUserRetriever
Initialize a user retrieval process
Attributes
ght[RW]
Public Class Methods
new(config, queue)
click to toggle source
# File lib/ghtorrent/commands/ght_retrieve_users.rb, line 22 def initialize(config, queue) @config = config @queue = queue end
Public Instance Methods
run(command)
click to toggle source
# File lib/ghtorrent/commands/ght_retrieve_users.rb, line 31 def run(command) processor = Proc.new do |user| @ght ||= TransactedGHTorrent.new(@config) retrieve_user(user) end command.queue_client(@queue, :after, processor) end
settings()
click to toggle source
# File lib/ghtorrent/commands/ght_retrieve_users.rb, line 27 def settings @config end
stop()
click to toggle source
# File lib/ghtorrent/commands/ght_retrieve_users.rb, line 43 def stop warn('Stop flag set, waiting for operations to finish') @stop = true end