sharpetronics/httpx
1
0
Fork 0
mirror of https://github.com/HoneyryderChuck/httpx.git synced 2025-10-04 00:00:37 -04:00
Code Issues Projects Releases Wiki Activity

selector: remove needless begin block

Browse Source
This commit is contained in:
HoneyryderChuck 2025-02-27 19:20:27 +00:00
parent 56d82e6370
commit f5aa6142a0
1 changed files with 11 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
lib/httpx/selector.rb
View File

@ -126,24 +126,22 @@ module HTTPX
# first, we group IOs based on interest type. On call to #interests however,
# things might already happen, and new IOs might be registered, so we might
# have to start all over again. We do this until we group all selectables
begin
@selectables.delete_if do |io|
interests = io.interests
@selectables.delete_if do |io|
interests = io.interests
(r ||= []) << io if READABLE.include?(interests)
(w ||= []) << io if WRITABLE.include?(interests)
(r ||= []) << io if READABLE.include?(interests)
(w ||= []) << io if WRITABLE.include?(interests)
io.state == :closed
end
io.state == :closed
end
# TODO: what to do if there are no selectables?
# TODO: what to do if there are no selectables?
readers, writers = IO.select(r, w, nil, interval)
readers, writers = IO.select(r, w, nil, interval)
if readers.nil? && writers.nil? && interval
[*r, *w].each { |io| io.handle_socket_timeout(interval) }
return
end
if readers.nil? && writers.nil? && interval
[*r, *w].each { |io| io.handle_socket_timeout(interval) }
return
end
if writers