lib/bunny/channel.rb in bunny-1.0.7 vs lib/bunny/channel.rb in bunny-1.1.0.pre1

- old
+ new

@@ -1679,11 +1679,11 @@ @basic_get_continuations.poll(@connection.continuation_timeout) ensure @threads_waiting_on_basic_get_continuations.delete(t) end else - connection.reader_loop.run_once until @basic_get_continuations.length > 0 + connection.event_loop.run_once until @basic_get_continuations.length > 0 @basic_get_continuations.pop end end @@ -1697,10 +1697,10 @@ @confirms_continuations.poll(@connection.continuation_timeout) ensure @threads_waiting_on_confirms_continuations.delete(t) end else - connection.reader_loop.run_once until @confirms_continuations.length > 0 + connection.event_loop.run_once until @confirms_continuations.length > 0 @confirms_continuations.pop end end