PingTimer

to11mtm · Apr 13, 2022 · c3cb8ee · c3cb8ee
1 parent 6ca273a
commit c3cb8ee
Show file tree

Hide file tree

Showing 4 changed files with 176 additions and 138 deletions.
diff --git a/sandbox/ConsoleApp/Program.cs b/sandbox/ConsoleApp/Program.cs
@@ -39,46 +39,20 @@ public static async Task Main()
             //LoggerFactory = new MinimumConsoleLoggerFactory(LogLevel.Information),
             Serializer = new MessagePackNatsSerializer(),
             ConnectTimeout = TimeSpan.FromSeconds(1),
-            ConnectOptions = ConnectOptions.Default with { Echo = true, Verbose = false }
+            ConnectOptions = ConnectOptions.Default with { Echo = true, Verbose = false },
+            PingInterval = TimeSpan.FromSeconds(5)
         };
 
 
 
 
         var connection = new NatsConnection(options);
 
-        await Parallel.ForEachAsync(Enumerable.Range(0, 100), new ParallelOptions { MaxDegreeOfParallelism = 100 }, async (i, ct) =>
-         {
-             var ttl = await connection.PingAsync();
-             Console.WriteLine(ttl);
-         });
-        Console.ReadLine();
-
-        await connection.PublishAsync("foo", 100);
-
-        await connection.SubscribeAsync<int>("foo", x =>
-        {
-            Console.WriteLine(x);
-        });
-
-        // Server
-        await connection.SubscribeRequestAsync<FooRequest, FooResponse>("hogemoge.key", req =>
-        {
-            Console.WriteLine("YEAH?");
-            return new FooResponse();
-        });
-
-        // Client
-        var response = await connection.RequestAsync<FooRequest, FooResponse>("hogemoge.key", new FooRequest());
-
+        await connection.ConnectAsync();
 
 
-        var ttl = await connection.PingAsync();
-        Console.WriteLine("RTT:" + ttl.TotalMilliseconds);
 
         Console.ReadLine();
-
-
     }
 
     //static void CalcCommandPushPop(NatsKey key, INatsSerializer serializer)