class Pull::Infinity

Constants

DEFAULT_ABORT_PROC

Public Class Methods

new(on_abort = DEFAULT_ABORT_PROC) click to toggle source
# File lib/pull/source/infinity.rb, line 9
def initialize(on_abort = DEFAULT_ABORT_PROC)
  @index = 0
end

Public Instance Methods

call() click to toggle source
# File lib/pull/source/infinity.rb, line 13
def call
  -> (finish, callback) {
    if finish
      on_abort.()
      return nil
    end

    callback.(@index)
    @index += 1
    return true
  }
end