remake of REST Controllers

backend/src/main/java/com/htopweb/system/SystemMetricsController.java

@@ -5,6 +5,10 @@ import com.htopweb.system.linux.*;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
+
+import java.util.List;
 
 @RestController
 @RequestMapping("/api/system")
@@ -12,9 +16,7 @@ public class SystemMetricsController {
 
     private final SystemMetricsService _systemMetricsService;
     private final LinuxDetailsService _linuxDetailsService;
-
     private final CpuDetailsService _cpuDetailsService;
-
     private final LinuxMemoryService _linuxMemoryService;
     private final LinuxDiskService _linuxDiskService;
     private final LinuxNetworkService _linuxNetworkService;
@@ -23,8 +25,9 @@ public class SystemMetricsController {
             SystemMetricsService systemMetricsService,
             LinuxDetailsService linuxDetailsService,
             CpuDetailsService cpuDetailsService,
-            LinuxMemoryService linuxMemoryService, LinuxDiskService linuxDiskService, LinuxNetworkService linuxNetworkService
+            LinuxMemoryService linuxMemoryService,
-
+            LinuxDiskService linuxDiskService,
+            LinuxNetworkService linuxNetworkService
     ) {
         _systemMetricsService = systemMetricsService;
         _linuxDetailsService = linuxDetailsService;
@@ -35,32 +38,38 @@ public class SystemMetricsController {
     }
 
     @GetMapping("/metrics")
-    public SystemMetricsResponse getMetrics() {
+    public Mono<SystemMetricsResponse> getMetrics() {
-        return _systemMetricsService.getMetrics();
+        return Mono.fromCallable(_systemMetricsService::getMetrics)
+                .subscribeOn(Schedulers.boundedElastic());
     }
 
     @GetMapping("/linux")
-    public LinuxDetailsResponse getLinuxDetails() {
+    public Mono<LinuxDetailsResponse> getLinuxDetails() {
-        return _linuxDetailsService.getDetails();
+        return Mono.fromCallable(_linuxDetailsService::getDetails)
+                .subscribeOn(Schedulers.boundedElastic());
     }
 
     @GetMapping("/cpu")
-    public CpuDetailsResponse getCpuDetails() {
+    public Mono<CpuDetailsResponse> getCpuDetails() {
-        return _cpuDetailsService.getDetails();
+        return Mono.fromCallable(_cpuDetailsService::getDetails)
+                .subscribeOn(Schedulers.boundedElastic());
     }
 
     @GetMapping("/linux/memory")
-    public LinuxMemoryResponse getLinuxMemory() {
+    public Mono<LinuxMemoryResponse> getLinuxMemory() {
-        return _linuxMemoryService.getDetails();
+        return Mono.fromCallable(_linuxMemoryService::getDetails)
+                .subscribeOn(Schedulers.boundedElastic());
     }
 
     @GetMapping("/linux/disks")
-    public java.util.List<LinuxDiskResponse> getLinuxDisks() {
+    public Mono<List<LinuxDiskResponse>> getLinuxDisks() {
-        return _linuxDiskService.getDisks();
+        return Mono.fromCallable(_linuxDiskService::getDisks)
+                .subscribeOn(Schedulers.boundedElastic());
     }
 
     @GetMapping("/linux/network")
-    public java.util.List<LinuxNetworkResponse> getLinuxNetwork() {
+    public Mono<List<LinuxNetworkResponse>> getLinuxNetwork() {
-        return _linuxNetworkService.getInterfaces();
+        return Mono.fromCallable(_linuxNetworkService::getInterfaces)
+                .subscribeOn(Schedulers.boundedElastic());
     }
 }

backend/src/main/java/com/htopweb/system/SystemProcessesController.java

@@ -1,8 +1,11 @@
+
 package com.htopweb.system;
 
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
 
 import java.util.List;
 
@@ -19,7 +22,8 @@ public class SystemProcessesController {
     }
 
     @GetMapping("/processes")
-    public List<ProcessInfoResponse> getProcesses() {
+    public Mono<List<ProcessInfoResponse>> getProcesses() {
-        return _systemProcessesService.getProcesses();
+        return Mono.fromCallable(_systemProcessesService::getProcesses)
+                .subscribeOn(Schedulers.boundedElastic());
     }
 }