summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authormo khan <mo.khan@gmail.com>2020-05-20 18:40:23 -0600
committermo khan <mo.khan@gmail.com>2020-05-20 18:40:23 -0600
commit1f74ee1f3d27c173e1630609df1464706d715c3b (patch)
tree54c1e6573d3a4c595802cc1f1e96d1f8ad8ee0ff
parente099378214541b75a7ddadd3e50781d1af294560 (diff)
Delete unused code
-rw-r--r--lib/spandx/core/concurrent.rb40
-rw-r--r--lib/spandx/core/line_io.rb23
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