Skip to content

Commit 893b76f

Browse files
authored
Merge pull request #32 from mmikhail2001/fix-infinite-taker-2
2 parents 808277b + e37911e commit 893b76f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

xqueue.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1503,7 +1503,7 @@ function methods:take(timeout, opts)
15031503
if not found then
15041504
local left = (now + timeout) - fiber.time()
15051505
if left <= 0 then goto finish end
1506-
1506+
if tube_chan and tube_chan:is_closed() then goto finish end
15071507
(tube_chan or xq.take_wait):get(left)
15081508
if box.session.storage.destroyed then goto finish end
15091509
end

0 commit comments

Comments
 (0)