From 30000efb14e8920ec2f6058eafbc225911773478 Mon Sep 17 00:00:00 2001 From: Mikhail Myadelets Date: Wed, 17 Dec 2025 15:09:58 +0300 Subject: [PATCH] init --- xqueue.lua | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/xqueue.lua b/xqueue.lua index 6f7313a..5a76742 100644 --- a/xqueue.lua +++ b/xqueue.lua @@ -1504,7 +1504,7 @@ function methods:take(timeout, opts) local left = (now + timeout) - fiber.time() if left <= 0 then goto finish end - (tube_chan or xq.take_wait):get(left) + (tube_chan and not tube_chan:is_closed() or xq.take_wait):get(left) if box.session.storage.destroyed then goto finish end end end