Racer example reports progress in realtime (#1000)

Author: JamesNK

examples/Racer/Client/Program.cs

@@ -39,7 +39,7 @@ static async Task Main(string[] args)
 
             await BidirectionalStreamingExample(client);
 
-            Console.WriteLine("Shutting down");
+            Console.WriteLine("Finished");
             Console.WriteLine("Press any key to exit...");
             Console.ReadKey();
         }
@@ -49,34 +49,56 @@ private static async Task BidirectionalStreamingExample(Racer.RacerClient client
             var headers = new Metadata { new Metadata.Entry("race-duration", RaceDuration.ToString()) };
 
             Console.WriteLine("Ready, set, go!");
-            using (var call = client.ReadySetGo(new CallOptions(headers)))
+            using var call = client.ReadySetGo(new CallOptions(headers));
+            var complete = false;
+
+            // Read incoming messages in a background task
+            RaceMessage? lastMessageReceived = null;
+            var readTask = Task.Run(async () =>
             {
+                await foreach (var message in call.ResponseStream.ReadAllAsync())
+                {
+                    lastMessageReceived = message;
+                }
+            });
+
+            // Write outgoing messages until timer is complete
+            var sw = Stopwatch.StartNew();
+            var sent = 0;
 
-                // Read incoming messages in a background task
-                RaceMessage? lastMessageReceived = null;
-                var readTask = Task.Run(async () =>
+            #region Reporting
+            // Report requests in realtime
+            var reportTask = Task.Run(async () =>
+            {
+                while (true)
                 {
-                    await foreach (var message in call.ResponseStream.ReadAllAsync())
+                    Console.WriteLine($"Messages sent: {sent}");
+                    Console.WriteLine($"Messages received: {lastMessageReceived?.Count ?? 0}");
+
+                    if (!complete)
                     {
-                        lastMessageReceived = message;
+                        await Task.Delay(TimeSpan.FromSeconds(1));
+                        Console.SetCursorPosition(0, Console.CursorTop - 2);
+                    }
+                    else
+                    {
+                        break;
                     }
-                });
-
-                // Write outgoing messages until timer is complete
-                var sw = Stopwatch.StartNew();
-                var sent = 0;
-                while (sw.Elapsed < RaceDuration)
-                {
-                    await call.RequestStream.WriteAsync(new RaceMessage { Count = ++sent });
                 }
+            });
+            #endregion
 
-                // Finish call and report results
-                await call.RequestStream.CompleteAsync();
-                await readTask;
-
-                Console.WriteLine($"Messages sent: {sent}");
-                Console.WriteLine($"Messages received: {lastMessageReceived?.Count ?? 0}");
+            while (sw.Elapsed < RaceDuration)
+            {
+                await call.RequestStream.WriteAsync(new RaceMessage { Count = ++sent });
             }
+
+            // Finish call and report results
+            await call.RequestStream.CompleteAsync();
+            await readTask;
+
+            complete = true;
+            await reportTask;
         }
     }
 }