We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 808277b + e37911e commit 893b76fCopy full SHA for 893b76f
1 file changed
xqueue.lua
@@ -1503,7 +1503,7 @@ function methods:take(timeout, opts)
1503
if not found then
1504
local left = (now + timeout) - fiber.time()
1505
if left <= 0 then goto finish end
1506
-
+ if tube_chan and tube_chan:is_closed() then goto finish end
1507
(tube_chan or xq.take_wait):get(left)
1508
if box.session.storage.destroyed then goto finish end
1509
end
0 commit comments