Run scalafmt

Author: arnavsharma990

frontend/src/main/scala/bloop/bsp/BspServer.scala

@@ -62,7 +62,7 @@ object BspServer {
     ): Task[State] = {
       val isCommunicationActive = Atomic(true)
       val connectionURI = handle.uri
-
+      // Do NOT change this log, it's used by clients to know when to start a connection
       logger.info(s"The server is listening for incoming connections at $connectionURI...")
       promiseWhenStarted.foreach(_.success(()))
 
@@ -87,7 +87,7 @@ object BspServer {
         scheduler,
         ioScheduler
       )
-
+      // In this case BloopLanguageServer doesn't use input observable
       val server =
         new BloopLanguageServer(Observable.never, client, provider.services, ioScheduler, bspLogger)
 
@@ -96,7 +96,7 @@ object BspServer {
         LowLevelMessage
           .fromInputStream(in, bspLogger)
           .guaranteeCase(_ => monix.eval.Task(inputExit.success(())))
-          .asyncBoundary(OverflowStrategy.Unbounded)
+          .asyncBoundary(OverflowStrategy.Unbounded) // allows to catch input stream close earlier
           .mapParallelUnordered(4) { bytes =>
             val msg = LowLevelMessage.toMsg(bytes)
             server
@@ -212,6 +212,7 @@ object BspServer {
       serverSocket: ServerSocket,
       socketPath: Option[Path] = None
   ): Unit = {
+    // Close any socket communication asap and swallow exceptions
     try {
       try socket.close()
       catch { case NonFatal(_) => () }
@@ -226,6 +227,7 @@ object BspServer {
         }
       }
     } finally {
+      // Guarantee that we always schedule the external classes directories deletion
       val deleteExternalDirsTasks = latestState.build.loadedProjects.map { loadedProject =>
         import bloop.io.Paths
         val project = loadedProject.project
@@ -252,4 +254,4 @@ object BspServer {
       ()
     }
   }
-}
+}