Contents

require 'gorgon/pipe_forker'

describe PipeForker do
  let(:io_pipe) { double("IO object", :close => nil)}
  let(:pipe) {double("Pipe", :write => io_pipe)}

  let(:container_class) do
    Class.new do
      extend(PipeForker)
    end
  end

  before do
    IO.stub(:pipe).and_return([io_pipe, io_pipe])
    STDIN.stub(:reopen)
    container_class.stub(:fork).and_yield.and_return(1)
    container_class.stub(:exit)
  end

  describe ".pipe_fork" do
    it "creates a new pipe" do
      IO.should_receive(:pipe).once.and_return ([io_pipe,io_pipe])
      container_class.pipe_fork { }
    end

    it "forks once" do
      container_class.should_receive(:fork).and_yield
      container_class.pipe_fork { }
    end

    it "closes both side of pipe inside child and read in parent" do
      io_pipe.should_receive(:close).exactly(3).times
      container_class.pipe_fork { }
    end

    it "reopens stdin with a pipe" do
      STDIN.should_receive(:reopen).with(io_pipe)
      container_class.pipe_fork { }
    end

    it "yields" do
      has_yielded = false
      container_class.pipe_fork { has_yielded = true }
      has_yielded.should be_true
    end

    it "returns pid of new process and a pipe" do
      pid, stdin = container_class.pipe_fork { }
      pid.should be 1
      stdin.should == io_pipe
    end
  end
end

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
gorgon-0.11.0	spec/pipe_forker_spec.rb
gorgon-0.10.5	spec/pipe_forker_spec.rb
gorgon-0.10.4	spec/pipe_forker_spec.rb
gorgon-0.10.3	spec/pipe_forker_spec.rb
gorgon-0.10.2	spec/pipe_forker_spec.rb
gorgon-0.10.1	spec/pipe_forker_spec.rb
gorgon-0.10.0	spec/pipe_forker_spec.rb
gorgon-0.9.0	spec/pipe_forker_spec.rb
gorgon-0.8.4	spec/pipe_forker_spec.rb
gorgon-0.8.3	spec/pipe_forker_spec.rb
gorgon-0.8.2	spec/pipe_forker_spec.rb
gorgon-0.8.1	spec/pipe_forker_spec.rb
gorgon-0.8.0	spec/pipe_forker_spec.rb
gorgon-0.7.1	spec/pipe_forker_spec.rb
gorgon-0.7.0	spec/pipe_forker_spec.rb