diff options
| author | mo khan <mo.khan@gmail.com> | 2020-05-20 18:40:23 -0600 |
|---|---|---|
| committer | mo khan <mo.khan@gmail.com> | 2020-05-20 18:40:23 -0600 |
| commit | 1f74ee1f3d27c173e1630609df1464706d715c3b (patch) | |
| tree | 54c1e6573d3a4c595802cc1f1e96d1f8ad8ee0ff | |
| parent | e099378214541b75a7ddadd3e50781d1af294560 (diff) | |
Delete unused code
| -rw-r--r-- | lib/spandx/core/concurrent.rb | 40 | ||||
| -rw-r--r-- | lib/spandx/core/line_io.rb | 23 |
2 files changed, 0 insertions, 63 deletions
diff --git a/lib/spandx/core/concurrent.rb b/lib/spandx/core/concurrent.rb deleted file mode 100644 index 7dd5e61..0000000 --- a/lib/spandx/core/concurrent.rb +++ /dev/null @@ -1,40 +0,0 @@ -# frozen_string_literal: true - -module Spandx - module Core - class Concurrent - include Enumerable - - def self.map(items, pool:, &block) - queue = Queue.new - - items.each do |item| - pool.schedule([item, block]) do |marshalled_item, callable| - queue.enq(callable.call(marshalled_item)) - end - end - - new(queue, items.size) - end - - attr_reader :queue, :size - - def initialize(queue, size) - @queue = queue - @size = size - end - - def each - size.times { yield queue.deq } - end - - def to_enum - Enumerator.new do |yielder| - each do |item| - yielder.yield item - end - end - end - end - end -end diff --git a/lib/spandx/core/line_io.rb b/lib/spandx/core/line_io.rb deleted file mode 100644 index e8c42e5..0000000 --- a/lib/spandx/core/line_io.rb +++ /dev/null @@ -1,23 +0,0 @@ -# frozen_string_literal: true - -module Spandx - module Core - class LineIo - def initialize(absolute_path) - file_descriptor = IO.sysopen(absolute_path) - @io = IO.new(file_descriptor) - @buffer = '' - end - - def each(&block) - @buffer << @io.sysread(512) until @buffer.include?($INPUT_RECORD_SEPARATOR) - - line, @buffer = @buffer.split($INPUT_RECORD_SEPARATOR, 2) - block.call(line) - each(&block) - rescue EOFError - @io.close - end - end - end -end |
