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