diff --git a/nats/aio/client.py b/nats/aio/client.py
index 81e65f50..e5ca2834 100644
--- a/nats/aio/client.py
+++ b/nats/aio/client.py
@@ -2084,7 +2084,9 @@ async def _flusher(self) -> None:
                 # RuntimeError in case the event loop is closed
                 break
             finally:
-                future.set_result(None)
+                # future might have been cancelled.  See issue #624
+                if not future.done():
+                    future.set_result(None)
 
     async def _ping_interval(self) -> None:
         while True: