Class: FuzzBert::Executor::DataProducer::ProcessSafeEnumerator

Inherits:

Object

• Object
• FuzzBert::Executor::DataProducer::ProcessSafeEnumerator

Defined in:

lib/fuzzbert/executor.rb

Overview

needed because the Fiber used for normal Enumerators has race conditions

Instance Method Summary

• #initialize(ary) ⇒ ProcessSafeEnumerator constructor

  A new instance of ProcessSafeEnumerator.

• #next ⇒ Object

Constructor Details

#initialize(ary) ⇒ ProcessSafeEnumerator

Returns a new instance of ProcessSafeEnumerator.

# File 'lib/fuzzbert/executor.rb', line 152

def initialize(ary)
  @i = 0
  @ary = ary.to_a
end

Instance Method Details

#next ⇒ Object

Raises:

• (StopIteration)

# File 'lib/fuzzbert/executor.rb', line 157

def next
  obj = @ary[@i]
  raise StopIteration unless obj
  @i += 1
  obj
end