Merge pull request #273 from silviorelli/master
Fix for fix on issue #260
This commit is contained in:
commit
73fc059634
1 file changed
+2
-1
@@ -273,7 +273,8 @@ private
|
|||||||
Thread.new do
|
Thread.new do
|
||||||
begin
|
begin
|
||||||
loop do
|
loop do
|
||||||
(IO.select(@readers.values, nil, nil, 30).first || []).each do |reader|
|
io = IO.select(@readers.values, nil, nil, 30)
|
||||||
|
(io.nil? ? [] : io.first).each do |reader|
|
||||||
data = reader.gets
|
data = reader.gets
|
||||||
output_with_mutex name_for(@readers.invert[reader]), data
|
output_with_mutex name_for(@readers.invert[reader]), data
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in new issue
Block a user