From 333fee1a8fd98a2fbff1ab187c1b03246a7eb01f Mon Sep 17 00:00:00 2001 From: Vladimir Mihailenco Date: Sun, 26 Dec 2021 16:42:17 +0200 Subject: [PATCH] fix: set timeout for WAIT command. Fixes #1963 --- commands.go | 1 + 1 file changed, 1 insertion(+) diff --git a/commands.go b/commands.go index dfe8d0bb..b5023399 100644 --- a/commands.go +++ b/commands.go @@ -431,6 +431,7 @@ func (c statefulCmdable) AuthACL(ctx context.Context, username, password string) func (c cmdable) Wait(ctx context.Context, numSlaves int, timeout time.Duration) *IntCmd { cmd := NewIntCmd(ctx, "wait", numSlaves, int(timeout/time.Millisecond)) + cmd.setReadTimeout(timeout) _ = c(ctx, cmd) return cmd }