diff --git a/conn.go b/conn.go index 5c8f51d..d78b09f 100644 --- a/conn.go +++ b/conn.go @@ -249,13 +249,18 @@ func (cc *Conn) Flush() error { return fmt.Errorf("SendMessages: %w", err) } + var errs error // Fetch the requested acknowledgement for each message we sent. for _, msg := range cc.messages { if _, err := receiveAckAware(conn, msg.Header.Flags); err != nil { - return fmt.Errorf("conn.Receive: %w", err) + errs = errors.Join(errs, err) } } + if errs != nil { + return fmt.Errorf("conn.Receive: %w", errs) + } + return nil }