lib/muxer/multiplexer.rb in muxer-0.1.1 vs lib/muxer/multiplexer.rb in muxer-0.1.2

@@ -53,10 +53,10 @@
         end
       end
     end
 
     def process_timeouts
-      if @timeout && Time.now >= finish
+      if @timeout && (@start + @timeout <= Time.now)
         finish_timeouts
         return
       end
       highest_remaining_timeout = @responses[:pending].map(&:timeout).max
       if highest_remaining_timeout && (@start + highest_remaining_timeout <= Time.now)
\ No newline at end of file