Contents

module DeadlySerious
  module Processes
    class ResilientSplitter
      def initialize
        @reallocate = false
        Signal.trap('USR1') do
          @reallocate = true
        end
      end

      def run(readers: [], writers: [])
        reader = readers.first
        outputs = writers.dup
        current = nil
        reader.each do |line|
          begin
            if @reallocate
              @reallocate = false
              outputs = writers.dup
            end
            current = outputs.first
            current << line
            outputs.rotate!
          rescue Errno::EPIPE => e
            puts e.inspect
            outputs.delete(current)
            raise e if outputs.empty?
            redo
          end
        end
      end
    end
  end
end

Version data entries

23 entries across 23 versions & 1 rubygems

Version	Path
deadly_serious-0.5.2	lib/deadly_serious/processes/resilient_splitter.rb
deadly_serious-0.5.1	lib/deadly_serious/processes/resilient_splitter.rb
deadly_serious-0.5.0	lib/deadly_serious/processes/resilient_splitter.rb