NIT Minor refactor of run --watch logic

Author: Gedochao

modules/build/src/main/scala/scala/build/Build.scala

@@ -305,9 +305,7 @@ object Build {
       testDocOpt: Option[Build]
     )
 
-    def doBuild(
-      overrideOptions: BuildOptions
-    ): Either[BuildException, NonCrossBuilds] = either {
+    def doBuild(overrideOptions: BuildOptions): Either[BuildException, NonCrossBuilds] = either {
 
       val inputs0 = updateInputs(
         inputs,
@@ -685,9 +683,9 @@ object Build {
     val threads     = BuildThreads.create()
     val classesDir0 = classesRootDir(inputs.workspace, inputs.projectName)
     val info = either {
-      val (crossSources, inputs0) = value(allInputs(inputs, options, logger))
-      val sharedOptions           = crossSources.sharedOptions(options)
-      val compiler = value {
+      val (crossSources: CrossSources, inputs0: Inputs) = value(allInputs(inputs, options, logger))
+      val sharedOptions                                 = crossSources.sharedOptions(options)
+      val compiler: ScalaCompiler = value {
         compilerMaker.create(
           inputs0.workspace / Constants.workspaceDirName,
           classesDir0,
@@ -696,7 +694,7 @@ object Build {
           sharedOptions
         )
       }
-      val docCompilerOpt = docCompilerMakerOpt.map(_.create(
+      val docCompilerOpt: Option[ScalaCompiler] = docCompilerMakerOpt.map(_.create(
         inputs0.workspace / Constants.workspaceDirName,
         classesDir0,
         buildClient,
@@ -711,20 +709,26 @@ object Build {
     def run(): Unit = {
       try {
         res =
-          info.flatMap { case (compiler, docCompilerOpt, crossSources, inputs) =>
-            build(
-              inputs,
-              crossSources,
-              options,
-              logger,
-              buildClient,
-              compiler,
-              docCompilerOpt,
-              crossBuilds = crossBuilds,
-              buildTests = buildTests,
-              partial = partial,
-              actionableDiagnostics = actionableDiagnostics
-            )
+          info.flatMap {
+            case (
+                  compiler: ScalaCompiler,
+                  docCompilerOpt: Option[ScalaCompiler],
+                  crossSources: CrossSources,
+                  inputs: Inputs
+                ) =>
+              build(
+                inputs = inputs,
+                crossSources = crossSources,
+                options = options,
+                logger = logger,
+                buildClient = buildClient,
+                compiler = compiler,
+                docCompilerOpt = docCompilerOpt,
+                crossBuilds = crossBuilds,
+                buildTests = buildTests,
+                partial = partial,
+                actionableDiagnostics = actionableDiagnostics
+              )
           }
         action(res)
       }
@@ -742,7 +746,7 @@ object Build {
 
     def doWatch(): Unit = {
       val elements: Seq[Element] =
-        if (res == null) inputs.elements
+        if res == null then inputs.elements
         else
           res
             .map { builds =>
@@ -777,10 +781,7 @@ object Build {
           case _: Virtual =>
         }
         watcher0.addObserver {
-          onChangeBufferedObserver { event =>
-            if (eventFilter(event))
-              watcher.schedule()
-          }
+          onChangeBufferedObserver(event => if eventFilter(event) then watcher.schedule())
         }
       }
 
@@ -797,14 +798,10 @@ object Build {
         }
         .getOrElse(Nil)
       for (artifact <- artifacts) {
-        val depth    = if (os.isFile(artifact)) -1 else Int.MaxValue
+        val depth    = if os.isFile(artifact) then -1 else Int.MaxValue
         val watcher0 = watcher.newWatcher()
         watcher0.register(artifact.toNIO, depth)
-        watcher0.addObserver {
-          onChangeBufferedObserver { _ =>
-            watcher.schedule()
-          }
-        }
+        watcher0.addObserver(onChangeBufferedObserver(_ => watcher.schedule()))
       }
     }
 

modules/cli/src/main/scala/scala/cli/commands/run/Run.scala

@@ -223,16 +223,15 @@ object Run extends ScalaCommand[RunOptions] with BuildCommandHelpers {
       Some(name),
       inputArgs
     )
-    if (CommandUtils.shouldCheckUpdate)
-      Update.checkUpdateSafe(logger)
+    if CommandUtils.shouldCheckUpdate then Update.checkUpdateSafe(logger)
 
     val configDb = ConfigDbUtils.configDb.orExit(logger)
     val actionableDiagnostics =
       options.shared.logging.verbosityOptions.actions.orElse(
         configDb.get(Keys.actions).getOrElse(None)
       )
 
-    if (options.sharedRun.watch.watchMode) {
+    if options.sharedRun.watch.watchMode then {
 
       /** A handle to the Runner process, used to kill the process if it's still alive when a change
         * occured and restarts are allowed or to wait for it if restarts are not allowed
@@ -251,20 +250,18 @@ object Run extends ScalaCommand[RunOptions] with BuildCommandHelpers {
       val mainThreadOpt = AtomicReference(Option.empty[Thread])
 
       val watcher = Build.watch(
-        inputs,
-        initialBuildOptions,
-        compilerMaker,
-        None,
-        logger,
+        inputs = inputs,
+        options = initialBuildOptions,
+        compilerMaker = compilerMaker,
+        docCompilerMakerOpt = None,
+        logger = logger,
         crossBuilds = cross,
         buildTests = false,
         partial = None,
         actionableDiagnostics = actionableDiagnostics,
         postAction = () =>
-          if (processOpt.get().exists(_._1.isAlive()))
-            WatchUtil.printWatchWhileRunningMessage()
-          else
-            WatchUtil.printWatchMessage()
+          if processOpt.get().exists(_._1.isAlive()) then WatchUtil.printWatchWhileRunningMessage()
+          else WatchUtil.printWatchMessage()
       ) { res =>
         for ((process, onExitProcess) <- processOpt.get()) {
           onExitProcess.cancel(true)
@@ -296,8 +293,7 @@ object Run extends ScalaCommand[RunOptions] with BuildCommandHelpers {
                   (proc, onExit)
               }
             s.copyOutput(options.shared)
-            if (options.sharedRun.watch.restart)
-              processOpt.set(maybeProcess)
+            if options.sharedRun.watch.restart then processOpt.set(maybeProcess)
             else {
               for ((proc, onExit) <- maybeProcess)
                 ProcUtil.waitForProcess(proc, onExit)