From a212aa300c1df0b2c6f2dfca7cff348f87c2b271 Mon Sep 17 00:00:00 2001
From: Torma <tormakristof@tormakristof.eu>
Date: Thu, 22 Oct 2020 19:28:27 +0200
Subject: [PATCH] infinite concurrency

---
 src/Application.kt | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/Application.kt b/src/Application.kt
index 6614543..ac0e704 100644
--- a/src/Application.kt
+++ b/src/Application.kt
@@ -15,21 +15,21 @@ fun main(args: Array<String>): Unit = io.ktor.server.tomcat.EngineMain.main(args
 @kotlin.jvm.JvmOverloads
 fun Application.module(testing: Boolean = false) {
     runBlocking {
-        var startTime : Instant
+        var startTime: Instant
         var elapsed = Duration.ofSeconds(0)
         val targetTime = Duration.ofSeconds(System.getenv("WAITTIME").toLong())
         var currIter = 1
-        val timestamps = LinkedHashMap<Int,Instant>()
-        var currTimeStamp : Instant
+        val timestamps = LinkedHashMap<Int, Instant>()
+        var currTimeStamp: Instant
         val uploader = Uploader()
         val processResults = ProcessResults()
         environment.monitor.subscribe(ApplicationStarted) {
-            val job = GlobalScope.launch {
-                println("Starting benchmark")
-                startTime = Instant.now()
-                while(elapsed < targetTime){
+            println("Starting benchmark")
+            startTime = Instant.now()
+            while (elapsed < targetTime) {
+                val job = GlobalScope.launch {
                     uploader.uploadData(currIter)
-                    currIter+=1
+                    currIter += 1
                     currTimeStamp = Instant.now()
                     timestamps[currIter] = currTimeStamp
                     elapsed = Duration.between(startTime, currTimeStamp)