lib/libvirt_async/handle.rb in libvirt_async-0.3.0 vs lib/libvirt_async/handle.rb in libvirt_async-0.3.1
- old
+ new
@@ -119,10 +119,10 @@
dbg { "#{self.class}#dispatch async starts handle_id=#{handle_id} events=#{events}, fd=#{fd}" }
Libvirt::Event.invoke_handle_callback(handle_id, fd, events, opaque)
dbg { "#{self.class}#dispatch async ends handle_id=#{handle_id} received_events=#{events}, fd=#{fd}" }
end
dbg { "#{self.class}#dispatch invokes fiber=0x#{task.fiber.object_id.to_s(16)} handle_id=#{handle_id}, events=#{events}, fd=#{fd}" }
- task.run
+ task.reactor << task.fiber
dbg { "#{self.class}#dispatch ends handle_id=#{handle_id}, events=#{events}, fd=#{fd}" }
end
def wait_io(interest)