Problem with TAsyncClient OnRead ( Never Called When Receive Data From Server) about mormot2 HOT 5 CLOSED

diff --git a/src/net/mormot.net.async.pas b/src/net/mormot.net.async.pas
index d9a500b7..589196ee 100644
--- a/src/net/mormot.net.async.pas
+++ b/src/net/mormot.net.async.pas
@@ -587,7 +587,8 @@ type
   // - will use a TAsyncConnection inherited class to maintain connection state
   // of each connected client
   TAsyncClient = class(TAsyncConnections)
-  protected
+  Protected
+    Function ConnectionCreate(aSocket: TNetSocket; Const aRemoteIp: RawUtf8; out aConnection: TAsyncConnection): Boolean; Override;
     procedure Execute; override;
   public
     /// start the TCP client connections, connecting to the supplied IP server
@@ -1714,12 +1715,7 @@ begin
     raise EAsyncConnections.CreateUtf8('%: %:% connection failure (%)',
       [self, fThreadClients.Address, fThreadClients.Port, ToText(res)^]);
   connection := nil;
-  if ConnectionCreate(client, {ip=}'', connection) then
-  begin
-    if fThreadReadPoll <> nil then
-      fThreadReadPoll.fEvent.SetEvent // awake reading thread(s)
-  end
-  else
+  if not ConnectionCreate(client, {ip=}'', connection) then
     client.ShutdownAndClose({rdwr=}false);
 end;
 
@@ -2282,6 +2278,23 @@ begin
     aLog, aOptions, aThreadPoolCount);
 end;
 
+function TAsyncClient.ConnectionCreate(aSocket: TNetSocket;
+  const aRemoteIp: RawUtf8; out aConnection: TAsyncConnection): Boolean;
+begin
+  result := false;
+  if not Terminated then
+  begin
+    aConnection := fConnectionClass.Create(self, aRemoteIp);
+    if inherited ConnectionAdd(aSocket, aConnection) then
+    begin
+      result := Clients.Start(aconnection); // assign a new connection to the internal reading poll
+      if Result then
+        if fThreadReadPoll <> nil then
+          fThreadReadPoll.fEvent.SetEvent; // awake reading thread(s)
+    end;
+  end;
+end;
+
 procedure TAsyncClient.Execute;
 var
   notif: TPollSocketResult;