lib/httpx/resolver/system.rb in httpx-1.3.0 vs lib/httpx/resolver/system.rb in httpx-1.3.1
- old
+ new
@@ -125,10 +125,10 @@
when DONE
*pair, addrs = @pipe_mutex.synchronize { @ips.pop }
@queries.delete(pair)
family, connection = pair
- emit_addresses(connection, family, addrs)
+ catch(:coalesced) { emit_addresses(connection, family, addrs) }
when ERROR
*pair, error = @pipe_mutex.synchronize { @ips.pop }
@queries.delete(pair)
family, connection = pair