update pubsub.go (#3329)

liushuangls · ofekshenawa · commit ef7f46a0db90 · 2025-08-11T01:42:45.000+03:00
diff --git a/pubsub.go b/pubsub.go
@@ -432,7 +432,7 @@ func (c *PubSub) ReceiveTimeout(ctx context.Context, timeout time.Duration) (int
 		return nil, err
 	}
 
-	err = cn.WithReader(context.Background(), timeout, func(rd *proto.Reader) error {
+	err = cn.WithReader(ctx, timeout, func(rd *proto.Reader) error {
 		return c.cmd.readReply(rd)
 	})
 

Original file line number	Diff line number	Diff line change
`@@ -432,7 +432,7 @@ func (c *PubSub) ReceiveTimeout(ctx context.Context, timeout time.Duration) (int`
`432`	`432`	`return nil, err`
`433`	`433`	`}`
`434`	`434`
`435`		`- err = cn.WithReader(context.Background(), timeout, func(rd *proto.Reader) error {`
	`435`	`+ err = cn.WithReader(ctx, timeout, func(rd *proto.Reader) error {`
`436`	`436`	`return c.cmd.readReply(rd)`
`437`	`437`	`})`
`438`	`438`