= EventMachine 

shutdown_wr_after_wrting implementation.

  def test_deferrable_child_process_with_input
    cat = ""
    EM.run {
      d = EM::DeferrableChildProcess.open( "cat" )
      d.send_data 'success result!'
      d.shutdown_wr_after_writing
      d.callback {|data_from_child|
        cat = data_from_child
        EM.stop
      }
    }
    assert( cat == 'success result!')
  end