fix: set timeout for WAIT command. Fixes #1963

vmihailenco · vmihailenco · commit 333fee1a8fd9 · 2021-12-26T16:42:17.000+02:00
diff --git 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
 }

Original file line number	Diff line number	Diff line change
`@@ -431,6 +431,7 @@ func (c statefulCmdable) AuthACL(ctx context.Context, username, password string)`
`431`	`431`
`432`	`432`	`func (c cmdable) Wait(ctx context.Context, numSlaves int, timeout time.Duration) *IntCmd {`
`433`	`433`	`cmd := NewIntCmd(ctx, "wait", numSlaves, int(timeout/time.Millisecond))`
	`434`	`+ cmd.setReadTimeout(timeout)`
`434`	`435`	`_ = c(ctx, cmd)`
`435`	`436`	`return cmd`
`436`	`437`	`}`