Scan command in pipeline cause infinite loop

[a791446794]

Scan command in pipeline cause infinite loop

Expected Behavior

Scan command return an iterator, then invoke iterator.Next(ctx) should forward scan cursor.

Current Behavior

block at iterator.Next()

Possible Solution

Steps to Reproduce

        ctx := context.Background()
	var cmd *redis.ScanCmd
	cmds, err := rdb.Pipelined(ctx, func(pipeliner redis.Pipeliner) error {
		_ = pipeliner.Scan(ctx, 0, "som:key:*", 1000)
		return nil
	})
	cmd = cmds[0].(*redis.ScanCmd)
	if err != nil {
		t.Error(cmd.Err())
		return
	}
	var cnt = 1
	iter := cmd.Iterator()
	var keys []string
	for {
		val := iter.Val()
		if val != "" {
			keys = append(keys, val)
		}
		if !iter.Next(ctx) { // infinite loop here
			break
		}
		if iter.Err() != nil {
			t.Error(iter.Err())
			return
		}
		cnt++
	}
	t.Logf("cnt:%d,result, len(%d):\n%s", cnt, len(keys), strings.Join(keys, "\n"))

Context (Environment)

redis/v9

Detailed Description

Possible Implementation

[github-actions]

This issue is marked stale. It will be closed in 30 days if it is not updated.