Call closure callback when aborting.

neo/lib/connection.py

@@ -480,6 +480,9 @@ class Connection(BaseConnection):
         neo.lib.logging.debug('aborting a connector for %r', self)
         self.aborted = True
         assert self.write_buf
+        if self._on_close is not None:
+            self._on_close()
+            self._on_close = None
 
     def writable(self):
         """Called when self is writable."""

neo/master/app.py

@@ -406,8 +406,6 @@ class Application(object):
             if node.isMaster():
                 continue
             conn = node.getConnection()
-            if node.isClient() and conn.isAborted():
-                continue
             node.notify(notification_packet)
             if node.isClient():
                 if state != ClusterStates.RUNNING: