Contents

module DeadlySerious
  module Processes
    class Joiner
      def run(readers: [], writers: [])
        writer = writers.first
        until readers.all?(&:eof?)
          readers.each do |reader|
            line = reader.gets
            writer << line if line
          end
        end
      end
    end
  end
end

Version data entries

28 entries across 28 versions & 1 rubygems

Version	Path
deadly_serious-1.0.2	lib/deadly_serious/processes/joiner.rb
deadly_serious-1.0.1	lib/deadly_serious/processes/joiner.rb
deadly_serious-1.0.0	lib/deadly_serious/processes/joiner.rb
deadly_serious-1.0.0.rc1	lib/deadly_serious/processes/joiner.rb
deadly_serious-1.0.0.pre	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.12.0	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.11.0	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.10.0	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.9.5	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.9.4	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.9.3	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.9.2	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.9.1	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.9.0	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.8.1	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.8.0	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.7.0	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.6.1	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.6.0	lib/deadly_serious/processes/joiner.rb
deadly_serious-0.5.3	lib/deadly_serious/processes/joiner.rb