ruby fiber fork

fiber_fork.rb

require 'eventmachine'
require 'em-synchrony'

fiber_fork = ->(cmd) {
  f = Fiber.current

  Fiber.new {
    reader, writer = IO.pipe
    fork {
      reader.close
      writer.write(`#{cmd}`)
      writer.close
    }
    writer.close
    data = ''
    while true do
      begin
        data << reader.read_nonblock(1024)
      rescue EOFError
        break
      rescue IO::WaitReadable
        EM::Synchrony.interrupt
      end
    end
    f.resume data
  }.resume
  Fiber.yield
}

EM.run do
  Fiber.new {
    (1..10).each { |i|
      p [:sleeping, i]
      EM::Synchrony.sleep 1
    }
  }.resume
  EM.synchrony do
    puts fiber_fork.('sleep 10; echo "foo"')
    EM.stop
  end
end