39 lines
1.0 KiB
Ruby
39 lines
1.0 KiB
Ruby
|
require 'helper'
|
||
|
|
|
||
|
|
class TestPipeDream < Test::Unit::TestCase
|
||
|
|
context "a pipe" do
|
||
|
|
setup do
|
||
|
|
@pipe = Hydra::Pipe.new
|
||
|
|
end
|
||
|
|
should "be able to write messages" do
|
||
|
|
Process.fork do
|
||
|
|
@pipe.identify_as_child
|
||
|
|
assert_equal "Test Message\n", @pipe.gets
|
||
|
|
@pipe.write "Message Received\n"
|
||
|
|
@pipe.write "Second Message\n"
|
||
|
|
@pipe.close
|
||
|
|
end
|
||
|
|
@pipe.identify_as_parent
|
||
|
|
@pipe.write "Test Message\n"
|
||
|
|
assert_equal "Message Received\n", @pipe.gets
|
||
|
|
assert !@pipe.eof?
|
||
|
|
assert_equal "Second Message\n", @pipe.gets
|
||
|
|
assert @pipe.eof?
|
||
|
|
assert_raise Hydra::PipeError::Broken do
|
||
|
|
@pipe.write "anybody home?"
|
||
|
|
end
|
||
|
|
@pipe.close
|
||
|
|
end
|
||
|
|
should "not allow writing if unidentified" do
|
||
|
|
assert_raise Hydra::PipeError::Unidentified do
|
||
|
|
@pipe.write "hey\n"
|
||
|
|
end
|
||
|
|
end
|
||
|
|
should "not allow reading if unidentified" do
|
||
|
|
assert_raise Hydra::PipeError::Unidentified do
|
||
|
|
@pipe.gets
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|