Sha256: 11c04137f069255b7491d6368bc23f0d684b56b7f5d6209d95c4e55499bc532a
Contents?: true
Size: 1.21 KB
Versions: 7
Compression:
Stored size: 1.21 KB
Contents
require "spec/helper/all" require "tempfile" DELAY = 0.1 describe EventMachine::Synchrony do before(:each) { @temp_file = Tempfile.new("stdout") } after(:each) { @temp_file.unlink } def with_input(string = "", &block) string = "#{string}\n" @temp_file.write string @temp_file.flush EM::Synchrony.add_timer(DELAY) do original_stdin = STDIN STDIN.reopen(@temp_file.path) block.call if block_given? STDIN.reopen(original_stdin) end end it "waits for input" do EM.synchrony do start = now with_input do EM::Synchrony.gets (now - start.to_f).should be_within(DELAY * 0.15).of(DELAY) end EM.add_timer(DELAY * 2) { EM.stop } end end it "trails input with a newline to emulate gets" do EM.synchrony do with_input("Hello") do EM::Synchrony.gets.should == "Hello\n" end EM.add_timer(DELAY * 2) { EM.stop } end end it "should stop after the first line" do EM.synchrony do with_input("Hello\nWorld!") do EM::Synchrony.gets.should == "Hello\n" end EM.add_timer(DELAY * 2) { EM.stop } end end end
Version data entries
7 entries across 7 versions & 1 rubygems