ReactiveX/RxRuby

# Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.

require 'rx/concurrency/scheduler'

module Rx
  # Abstract base class for machine-local schedulers, using the local system clock for time-based operations.
  class LocalScheduler

    include Scheduler

    # Gets the scheduler's notion of current time.
    def now
      Time.now
    end

    # Schedules an action to be executed.
    def schedule_with_state(state, action)
      raise 'action cannot be nil' unless action

      schedule_relative_with_state(state, 0, action)
    end

    # Schedules an action to be executed at dueTime.
    def schedule_absolute_with_state(state, due_time, action)
      raise 'action cannot be nil' unless action

      schedule_relative_with_state(state, (due_time - self.now), action)
    end

    def schedule_relative_with_state(state, due_time, action)
      raise ArgumentError.new 'action cannot be nil' unless action

      dt = Rx::Scheduler.normalize due_time
      sleep dt if dt > 0
      action.call(self, state)
    end

  end
end