Contents

require 'fileutils'

module DeadlySerious
  module Engine
    # Wraps the channels with a  {LazyIO} before pass
    # them to the component.
    module OpenIo
      def run(*args, readers: [], writers:[])
        opened_readers = readers.map { |reader| wrap_io(reader) }
        opened_writers = writers.map { |writer| wrap_io(writer) }
        super(*args, readers: opened_readers, writers: opened_writers)
      ensure
        if opened_writers
          opened_writers.each { |writer| close_io(writer) }
        end
        if opened_readers
          opened_readers.each { |reader| close_io(reader) }
        end
      end

      private

      def close_io(io)
        return unless io
        return if io.closed?
        io.close
      rescue => e
        # Intentionally eat the error
        # because it's being used inside
        # an "ensure" block
        puts e.inspect
      end

      def wrap_io(pipe_name)
        Channel.new(pipe_name).io
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
deadly_serious-0.12.0	lib/deadly_serious/engine/open_io.rb