(ctx context.Context, numSlaves int, timeout time.Duration)
| 290 | } |
| 291 | |
| 292 | func (c cmdable) Wait(ctx context.Context, numSlaves int, timeout time.Duration) *IntCmd { |
| 293 | cmd := NewIntCmd(ctx, "wait", numSlaves, int(timeout/time.Millisecond)) |
| 294 | cmd.setReadTimeout(timeout) |
| 295 | _ = c(ctx, cmd) |
| 296 | return cmd |
| 297 | } |
| 298 | |
| 299 | func (c cmdable) WaitAOF(ctx context.Context, numLocal, numSlaves int, timeout time.Duration) *IntCmd { |
| 300 | cmd := NewIntCmd(ctx, "waitAOF", numLocal, numSlaves, int(timeout/time.Millisecond)) |