Contents

module Elevate
  def async(args = {}, &block)
    with_operation(args, block) do |operation|
      queue.addOperation(operation)
    end
  end

  private

  def queue
    Dispatch.once do
      $elevate_queue = NSOperationQueue.alloc.init
      $elevate_queue.maxConcurrentOperationCount = 1
    end

    $elevate_queue
  end

  def with_operation(args, dsl_block, &block)
    dsl = DSL.new(&dsl_block)

    raise "No task block specified!" unless dsl.task_callback

    operation = ElevateOperation.alloc.initWithTarget(dsl.task_callback, args: args)
    operation.on_started  = Callback.new(self, dsl.started_callback)  if dsl.started_callback
    operation.on_finished = Callback.new(self, dsl.finished_callback) if dsl.finished_callback

    yield operation

    operation
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
elevate-0.4.0	lib/elevate/api.rb