ruby 如何使用Typheus中止on_body回调中的当前请求

nfeuvbwi 于 2022-12-22 发布在 Ruby

关注(0)|答案(2)|浏览(86)

我使用Typheus处理一个包含十几个请求的九头蛇队列。
我使用on_body回调来流式传输响应。
当然，在不中止队列中所有其他请求的情况下，中止此回调中的当前请求（即达到最大文件大小...）的最佳方法是什么？

hydra = Typhoeus::Hydra.hydra

urls.each do |url|
  request = Typhoeus::Request.new(url, followlocation: true, timeout: 5, connecttimeout: 5)
  request.on_body do |chunk, response|
    #
    # How to conditionally abort the request here ?
    #        
  end

  hydra.queue request
end

hydra.run

ruby

来源：https://stackoverflow.com/questions/23383959/how-to-abort-current-request-in-on-body-callback-using-typhoeus

2条答案

按热度按时间

pcrecxhr1#

There is no way at the moment. According to http://curl.haxx.se/libcurl/c/curl_easy_setopt.html#CURLOPTWRITEFUNCTION it would be enough to return an invalid size. But that is not an option yet in Typhoeus since the callback itself is wrapped and it always returns the correct size: https://github.com/typhoeus/ethon/blob/master/lib/ethon/easy/callbacks.rb#L37-48.
编辑：Ethon 0.7.1能够中止on_body回调中的请求：https://github.com/typhoeus/ethon/commit/6117872004c9ed1dac0ac15542dffc10177d8eae.

赞(0）回复(0）举报 2022-12-22

c0vxltue2#

根据README，Typheus现在有一种方法来中断on_body回调。
返回:abort符号：

request.on_body do |chunk|
  # [do stuff with the chunk]
  :abort if [some terminating condition]
end

赞(0）回复(0）举报 2022-12-22

我来回答

ruby 如何使用Typheus中止on_body回调中的当前请求

2条答案

相关问题

热门标签

最新问答