check request error during (Un)Subscribe completion

srishina · srishina · commit 0ec9621bea3b · 2024-09-17T06:54:04.000+05:30
diff --git a/client.go b/client.go
@@ -361,8 +361,12 @@ func (c *client) Unsubscribe(ctx context.Context, topicFilters []string, props *
 	case result = <-req.result:
 	}
 
+	if req.err != nil {
+		return nil, req.err
+	}
+
 	if unsuback, ok := result.(*UnsubAck); ok {
-		return unsuback, req.err
+		return unsuback, nil
 	}
 
 	return nil, fmt.Errorf("error during UNSUBSCRIBE, invalid typs received")

Original file line number	Diff line number	Diff line change
`@@ -361,8 +361,12 @@ func (c client) Unsubscribe(ctx context.Context, topicFilters []string, props `
`361`	`361`	`case result = <-req.result:`
`362`	`362`	`}`
`363`	`363`
	`364`	`+ if req.err != nil {`
	`365`	`+ return nil, req.err`
	`366`	`+ }`
	`367`	`+`
`364`	`368`	`if unsuback, ok := result.(*UnsubAck); ok {`
`365`		`- return unsuback, req.err`
	`369`	`+ return unsuback, nil`
`366`	`370`	`}`
`367`	`371`
`368`	`372`	`return nil, fmt.Errorf("error during UNSUBSCRIBE, invalid typs received")`