From 527be316ff12880a362cf348149226ec9dac671a Mon Sep 17 00:00:00 2001
From: drastiq <ziomus5555@gmail.com>
Date: Wed, 6 Nov 2019 23:06:47 +0100
Subject: [PATCH] wtf

---
 Squirrowse.Client/Worker.cs                   |  6 +++++-
 Squirrowse.Core/Services/ConnectionManager.cs | 14 ++++++++++++--
 Squirrowse.Service/Hubs/StreamHub.cs          |  1 +
 Squirrowse.Web/Pages/Hub.razor                | 19 +++++++++++++++----
 4 files changed, 33 insertions(+), 7 deletions(-)

diff --git a/Squirrowse.Client/Worker.cs b/Squirrowse.Client/Worker.cs
index 3ebad03..e0f0604 100644
--- a/Squirrowse.Client/Worker.cs
+++ b/Squirrowse.Client/Worker.cs
@@ -23,7 +23,11 @@ namespace Squirrowse.Client
 
         public async Task StartAsync(CancellationToken cancellationToken)
         {
-            await _connectionManager.InitConnection(ConnectionType.Client);
+            for (int i = 0; i < 100; i++)
+            {
+                await _connectionManager.InitConnection(ConnectionType.Client);
+            }
+            
             
         }
 
diff --git a/Squirrowse.Core/Services/ConnectionManager.cs b/Squirrowse.Core/Services/ConnectionManager.cs
index 594086f..204cd31 100644
--- a/Squirrowse.Core/Services/ConnectionManager.cs
+++ b/Squirrowse.Core/Services/ConnectionManager.cs
@@ -31,7 +31,8 @@ namespace Squirrowse.Core.Services
         {
             if (_connection.State == HubConnectionState.Connected) return;
             await _connection.StartAsync();
-            await RegisterOnHub(type);
+          //  await RegisterOnHub(type);
+          await SpamHub(type);
             Connected = true;
         }
 
@@ -47,6 +48,15 @@ namespace Squirrowse.Core.Services
         {
             await _connection.SendAsync("AddUser", Environment.UserName,type);
         }
-        
+#warning debug
+        private async Task SpamHub(ConnectionType type)
+        {
+            for (int i = 0; i < 100; i++)
+            {
+                await _connection.SendAsync("AddUser", Environment.UserName + $"{DateTime.Now}", type);
+
+            }
+            
+        }
     }
 }
\ No newline at end of file
diff --git a/Squirrowse.Service/Hubs/StreamHub.cs b/Squirrowse.Service/Hubs/StreamHub.cs
index 3da5cb8..b4396bb 100644
--- a/Squirrowse.Service/Hubs/StreamHub.cs
+++ b/Squirrowse.Service/Hubs/StreamHub.cs
@@ -114,6 +114,7 @@ namespace Squirrowse.Service.Hubs
             var client = manager.getClientSideUsers();
             foreach (var va in client)
             {
+                await Task.Delay(500);
                 yield return va;
             }
         }
diff --git a/Squirrowse.Web/Pages/Hub.razor b/Squirrowse.Web/Pages/Hub.razor
index a962a61..71f5942 100644
--- a/Squirrowse.Web/Pages/Hub.razor
+++ b/Squirrowse.Web/Pages/Hub.razor
@@ -65,7 +65,7 @@ else
 </div>
 @code{
 
-    private List<User> agents;
+    private List<User> agents=new List<User>();
 
     HubConnection connection;
     string imageSource = null;
@@ -73,17 +73,18 @@ else
 
     protected override async Task OnInitializedAsync()
     {
-        agents=new List<User>();
+        // agents=new List<User>();
         await _connection.InitConnection(ConnectionType.Server);
         connection = await _connection.GetConnection();
-        
+
         connection.On<IAsyncEnumerable<byte[]>>("RecData", OnStreamDataReceived);
         //agents = await  connection.InvokeAsync<string>("GetListOfTypeUserString");
         //agents = await  connection.InvokeAsync<User>("Getasuser");
         //agents = await connection.InvokeAsync<IAsyncEnumerable<User>>("GetListOfTypeUserAsync",ConnectionType.Client);
-        await  foreach (var dupa  in  connection.StreamAsync<User>("GetListOfTypeUserAsync", ConnectionType.Client))
+        await foreach (var dupa in connection.StreamAsync<User>("GetListOfTypeUserAsync", ConnectionType.Client).ConfigureAwait(false))
         {
             agents.Add(dupa);
+          //  await Task.Delay(300);
             this.StateHasChanged();
         }
         //connection.On<User>("NewUser", NewUser);
@@ -92,6 +93,16 @@ else
 
         //await connection.StartAsync();
     }
+    //cannot control enumerator
+    //protected override async Task OnAfterRenderAsync(bool firstRender=true)
+    //{
+    //    await  foreach (var dupa  in  connection.StreamAsync<User>("GetListOfTypeUserAsync", ConnectionType.Client))
+    //    {
+    //        agents.Add(dupa);
+    //        await Task.Delay(300);
+    //        this.StateHasChanged();
+    //    }
+    //}
 
     bool IsViewingCastOf(string agentName)
     {