Replace error atomic.Value with error atomic.Pointer[errs]

pipe.go

@@ -61,7 +61,7 @@ var _ wire = (*pipe)(nil)
 
 type pipe struct {
 	conn            net.Conn
-	error           atomic.Value
+	error           atomic.Pointer[errs]
 	clhks           atomic.Value // closed hook, invoked after the conn is closed
 	pshks           atomic.Value // pubsub hook, registered by the SetPubSubHooks
 	queue           queue
@@ -337,6 +337,9 @@ func (p *pipe) background() {
 }
 
 func (p *pipe) _exit(err error) {
+	if err != nil {
+        	p.error.Store(&errs{error: err}) 
+    	}
 	p.error.CompareAndSwap(nil, &errs{error: err})
 	atomic.CompareAndSwapInt32(&p.state, 1, 2) // stop accepting new requests
 	_ = p.conn.Close()                         // force both read & write goroutine to exit
@@ -1544,12 +1547,16 @@ func (p *pipe) DoMultiCache(ctx context.Context, multi ...CacheableTTL) *redisre
 }
 
 func (p *pipe) Error() error {
-	if err, ok := p.error.Load().(*errs); ok {
-		return err.error
-	}
-	return nil
+    errPtr := p.error.Load()
+    if errPtr == nil {
+        return nil 
+    }
+    return errPtr.error
 }
 
+
+
+
 func (p *pipe) Close() {
 	p.error.CompareAndSwap(nil, errClosing)
 	block := atomic.AddInt32(&p.blcksig, 1)