Sha256: 92298c6391b3d86c419b612f2ba5dbf42b163280f122a6675651bda5ece4370e
Contents?: true
Size: 1.25 KB
Versions: 11
Compression:
Stored size: 1.25 KB
Contents
# frozen_string_literal: true
# @api private
# @since 0.1.0
class SmartCore::Validator::CommandSet
# @since 0.1.0
include Enumerable
# @return [Array<SmartCore::Validator::Commands::Base>]
#
# @api private
# @since 0.1.0
attr_reader :commands
# @api private
# @since 0.1.0
def initialize
@commands = []
@access_lock = Mutex.new
end
# @param command [SmartCore::Validator::Commands::Base]
# @return [void]
#
# @api private
# @since 0.1.0
def add_command(command)
thread_safe { commands << command }
end
alias_method :<<, :add_command
# @yield [SmartCore::Validator::Commands::Base]
# @return [Enumerable]
#
# @api private
# @since 0.1.0
def each(&block)
thread_safe { block_given? ? commands.each(&block) : commands.each }
end
# @param command_set [SmartCore::Validator::CommandSet]
# @return [void]
#
# @api private
# @since 0.1.0
def concat(command_set)
thread_safe { commands.concat(command_set.commands) }
end
# @return [void]
#
# @api private
# @since 0.1.0
def clear
thread_safe { commands.clear }
end
private
# @param block [Proc]
# @return [Any]
#
# @api private
# @since 0.1.0
def thread_safe(&block)
@access_lock.synchronize(&block)
end
end
Version data entries
11 entries across 11 versions & 1 rubygems