🐛 Fixed progress bar

plume-oss · Mar 23, 2021 · 0f3d3ae · 0f3d3ae
1 parent 1289315
commit 0f3d3ae
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/plume/src/main/kotlin/io/github/plume/oss/Extractor.kt b/plume/src/main/kotlin/io/github/plume/oss/Extractor.kt
@@ -303,7 +303,7 @@ class Extractor(val driver: IDriver) {
                 // Consumer: Receive delta graphs and write changes to the driver in serial
                 launch {
                     runInsideProgressBar("Method Heads", headsToBuild.size.toLong()) { pb ->
-                        repeat(headsToBuild.size) { launch { channel.receive().apply(driver); pb?.step() } }
+                        repeat(headsToBuild.size) { launch { channel.receive().apply(driver) }; pb?.step() }
                     }
                     logger.debug("All ${headsToBuild.size} method heads have been applied to the driver")
                 }.join() // Suspend until the channel is fully consumed.
@@ -319,7 +319,7 @@ class Extractor(val driver: IDriver) {
                 // Consumer: Receive delta graphs and write changes to the driver in serial
                 launch {
                     runInsideProgressBar("Method Bodies", bodiesToBuild.size.toLong()) { pb ->
-                        repeat(bodiesToBuild.size) { launch { channel.receive().apply(driver); pb?.step() } }
+                        repeat(bodiesToBuild.size) { launch { channel.receive().apply(driver) }; pb?.step() }
                     }
                     logger.debug("All ${bodiesToBuild.size} method bodies have been applied to the driver")
                 }.join() // Suspend until the channel is fully consumed.
@@ -339,7 +339,7 @@ class Extractor(val driver: IDriver) {
                 // Consumer: Receive delta graphs and write changes to the driver in serial
                 launch {
                     runInsideProgressBar("Method Calls", bodiesToBuild.size.toLong()) { pb ->
-                        repeat(bodiesToBuild.size) { launch { channel.receive().apply(driver); pb?.step() } }
+                        repeat(bodiesToBuild.size) { launch { channel.receive().apply(driver) }; pb?.step() }
                     }
                     logger.debug("All ${bodiesToBuild.size} method calls have been applied to the driver")
                 }.join() // Suspend until the channel is fully consumed.