From 68c4344e6ca3d4e0fd982cfb180bfc98b32a8baf Mon Sep 17 00:00:00 2001
From: Gengland <george@GGT-LT228-MBP.local>
Date: Thu, 14 Jul 2022 17:31:45 -0400
Subject: [PATCH] flusher error calls async callback

---
 nats.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/nats.go b/nats.go
index 81f51335f..f4d454b17 100644
--- 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()