Contents

# frozen_string_literal: true

# @api private
# @since 0.5.0
class SmartCore::Container::CommandSet
  # @since 0.5.0
  include Enumerable

  # @return [Array<SmartCore::Container::Commands::Base>]
  #
  # @api private
  # @since 0.5.0
  attr_reader :commands

  # @api private
  # @since 0.5.0
  def initialize
    @commands = []
    @access_lock = Mutex.new
  end

  # @param command [SmartCore::Container::Commands::Base]
  # @return [void]
  #
  # @api private
  # @since 0.5.0
  def add_command(command)
    thread_safe { commands << command }
  end
  alias_method :<<, :add_command

  # @yield [SmartCore::Container::Commands::Base]
  # @return [Enumerable]
  #
  # @api private
  # @since 0.5.0
  def each(&block)
    thread_safe { block_given? ? commands.each(&block) : commands.each }
  end

  # @param command_set [SmartCore::Container::CommandSet]
  # @return [void]
  #
  # @api private
  # @since 0.5.0
  def concat(command_set)
    thread_safe { commands.concat(command_set.dup.commands) }
  end

  # @return [SmartCore::Operation::AttributeSet]
  #
  # @api private
  # @since 0.2.0
  def dup
    thread_safe do
      self.class.new.tap do |duplicate|
        commands.each do |command|
          duplicate.add_command(command.dup)
        end
      end
    end
  end

  # @return [void]
  #
  # @api private
  # @since 0.5.0
  def clear
    thread_safe { commands.clear }
  end

  private

  # @param block [Proc]
  # @return [Any]
  #
  # @api private
  # @since 0.5.0
  def thread_safe(&block)
    @access_lock.synchronize(&block)
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
smart_core-0.6.0	lib/smart_core/container/command_set.rb
smart_core-0.5.2	lib/smart_core/container/command_set.rb
smart_core-0.5.1	lib/smart_core/container/command_set.rb
smart_core-0.5.0	lib/smart_core/container/command_set.rb