Fix multiple threads reading stream.

immense · Apr 25, 2020 · f78bb03 · f78bb03
1 parent ab33954
commit f78bb03
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/Agent/Services/ChatClientService.cs b/Agent/Services/ChatClientService.cs
@@ -52,6 +52,7 @@ public async Task SendMessage(string message, string orgName, string senderConne
                             return;
                         }
                         chatSession = new ChatSession() { PipeStream = clientPipe, ProcessID = procID };
+                        _ = Task.Run(async () => { await ReadFromStream(chatSession.PipeStream, senderConnectionID, hubConnection); });
                         ChatClients.Add(senderConnectionID, chatSession, CacheItemPolicy);
                     }
 
@@ -69,8 +70,6 @@ public async Task SendMessage(string message, string orgName, string senderConne
                         await sw.WriteLineAsync(message);
                         await sw.FlushAsync();
                     }
-
-                    _ = Task.Run(async () => { await ReadFromStream(chatSession.PipeStream, senderConnectionID, hubConnection); });
                 }
             }
             catch (Exception ex)