test: the pipeline of rueidiscompat

Signed-off-by: Rueian <rueiancsie@gmail.com>
redis · Aug 20, 2024 · 7f598a2 · 7f598a2
1 parent fced78b
commit 7f598a2
Show file tree

Hide file tree

Showing 2 changed files with 950 additions and 1 deletion.
diff --git a/rueidiscompat/pipeline.go b/rueidiscompat/pipeline.go
@@ -29,6 +29,7 @@ package rueidiscompat
 import (
 	"context"
 	"errors"
+	"runtime"
 	"time"
 	"unsafe"
 
@@ -85,7 +86,7 @@ func (p *proxy) Do(_ context.Context, cmd rueidis.Completed) rueidis.RedisResult
 }
 
 func newPipeline(real rueidis.Client) *Pipeline {
-	return &Pipeline{comp: Compat{client: &proxy{Client: real}}}
+	return &Pipeline{comp: Compat{client: &proxy{Client: real}, maxp: runtime.GOMAXPROCS(0), pOnly: true}}
 }
 
 // Pipeline implements pipelining as described in