Contents

# frozen_string_literal: true

module Pull
  class Infinity
    DEFAULT_ABORT_PROC = -> () {
      puts "abort abort"
    }

    def initialize(on_abort = DEFAULT_ABORT_PROC)
      @index = 0
    end

    def call
      -> (finish, callback) {
        if finish
          on_abort.()
          return nil
        end

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

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
pull_stream-1.0.0	lib/pull/source/infinity.rb