Merge pull request #35 from Gold872/latency-decimal

Changed network latency to a decimal value
Gold872 · Apr 28, 2024 · dccdcd7 · dccdcd7
2 parents bc2ead6 + 9af989e
commit dccdcd7
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/lib/pages/dashboard_page.dart b/lib/pages/dashboard_page.dart
@@ -1565,10 +1565,10 @@ class _DashboardPageState extends State<DashboardPage> with WindowListener {
                               ntConnection.latencyStream()),
                           builder: (context, snapshot) {
                             double bandwidth = snapshot.snapshot1.data ?? 0.0;
-                            int latency = snapshot.snapshot2.data ?? 0;
+                            double latency = snapshot.snapshot2.data ?? 0.0;
 
                             return Text(
-                              '${bandwidth.toStringAsFixed(2).padLeft(5)} kb/s | ${latency.toString().padLeft(1)} ms',
+                              '${bandwidth.toStringAsFixed(2).padLeft(5)} kb/s | ${latency.toStringAsFixed(2).padLeft(4)} ms',
                               textAlign: TextAlign.right,
                             );
                           }),

diff --git a/lib/services/nt4_client.dart b/lib/services/nt4_client.dart
@@ -256,7 +256,7 @@ class NT4Client {
   final Map<int, NT4Topic> announcedTopics = {};
   int _clientId = 0;
   int _serverTimeOffsetUS = 0;
-  int _latencyMs = 0;
+  double _latencyMs = 0;
   int _bitUsage = 0;
   double _dataRateKbPerSecond = 0;
 
@@ -297,10 +297,10 @@ class NT4Client {
     _wsOnClose();
   }
 
-  Stream<int> latencyStream() async* {
+  Stream<double> latencyStream() async* {
     yield _latencyMs;
 
-    int lastYielded = _latencyMs;
+    double lastYielded = _latencyMs;
 
     while (true) {
       await Future.delayed(const Duration(seconds: 1));
@@ -543,7 +543,7 @@ class NT4Client {
 
     _lastPongTime = rxTime;
 
-    _latencyMs = (rtt / 2) ~/ 1000;
+    _latencyMs = (rtt / 2) / 1000;
   }
 
   void _wsSubscribe(NT4Subscription sub) {

diff --git a/lib/services/nt_connection.dart b/lib/services/nt_connection.dart
@@ -116,7 +116,7 @@ class NTConnection {
     }
   }
 
-  Stream<int> latencyStream() {
+  Stream<double> latencyStream() {
     return nt4Client.latencyStream();
   }
-Original file line number
+Diff line change
@@ Expand Up / @@ -116,7 +116,7 @@ class NTConnection { @@
         }
       }
-      Stream<int> latencyStream() {
+      Stream<double> latencyStream() {
         return nt4Client.latencyStream();
       }
@@ Expand Down @@