Merge pull request #1015 from GeorgeEngland/main

flusher errors now do not fail silently
nats-io · Jul 14, 2022 · f4a86f3 · f4a86f3
2 parents 2d22c44 + 68c4344
commit f4a86f3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/nats.go b/nats.go
@@ -3095,6 +3095,9 @@ func (nc *Conn) flusher() {
 				if nc.err == nil {
 					nc.err = err
 				}
+				if nc.Opts.AsyncErrorCB != nil {
+					nc.ach.push(func() { nc.Opts.AsyncErrorCB(nc, nil, err) })
+				}
 			}
 		}
 		nc.mu.Unlock()