Skip to content

Commit 2b3e122

Browse files
authored
More tweaks to simplify BSP logic (#2521)
The initial call to `updateEvaluator` always happens with `None`, which makes it a no-op
1 parent 65dd1f5 commit 2b3e122

File tree

4 files changed

+1
-9
lines changed

4 files changed

+1
-9
lines changed

bsp/src/mill/bsp/BspContext.scala

-3
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ class BspContext(streams: SystemStreams, bspLogStream: Option[PrintStream], home
2222
BspContext.bspServerHandle =
2323
try {
2424
startBspServer(
25-
initialEvaluator = None,
2625
streams = streams,
2726
logStream = bspLogStream,
2827
canReload = true
@@ -39,7 +38,6 @@ class BspContext(streams: SystemStreams, bspLogStream: Option[PrintStream], home
3938
streams.err.println("BSP server started")
4039

4140
def startBspServer(
42-
initialEvaluator: Option[Evaluator],
4341
streams: SystemStreams,
4442
logStream: Option[PrintStream],
4543
canReload: Boolean
@@ -62,7 +60,6 @@ class BspContext(streams: SystemStreams, bspLogStream: Option[PrintStream], home
6260
BspWorker(os.pwd, home, log).flatMap { worker =>
6361
os.makeDir.all(home / Constants.bspDir)
6462
worker.startBspServer(
65-
initialEvaluator,
6663
streams,
6764
logStream.getOrElse(streams.err),
6865
home / Constants.bspDir,

bsp/src/mill/bsp/BspWorker.scala

-1
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@ import java.net.URL
1010
@internal
1111
trait BspWorker {
1212
def startBspServer(
13-
initialEvaluator: Option[Evaluator],
1413
streams: SystemStreams,
1514
logStream: PrintStream,
1615
logDir: os.Path,

bsp/worker/src/mill/bsp/worker/BspWorkerImpl.scala

-3
Original file line numberDiff line numberDiff line change
@@ -15,17 +15,14 @@ import scala.concurrent.{Await, CancellationException, Promise}
1515
private class BspWorkerImpl() extends BspWorker {
1616

1717
override def startBspServer(
18-
initialEvaluator: Option[Evaluator],
1918
streams: SystemStreams,
2019
logStream: PrintStream,
2120
logDir: os.Path,
2221
canReload: Boolean
2322
): Either[String, BspServerHandle] = {
24-
val evaluator = initialEvaluator.map(_.withFailFast(false))
2523

2624
val millServer =
2725
new MillBuildServer(
28-
initialEvaluator = evaluator,
2926
bspVersion = Constants.bspProtocolVersion,
3027
serverVersion = MillBuildInfo.millVersion,
3128
serverName = Constants.serverName,

bsp/worker/src/mill/bsp/worker/MillBuildServer.scala

+1-2
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,6 @@ import scala.util.{Failure, Success, Try}
7474
import Utils.sanitizeUri
7575
import mill.bsp.BspServerResult
7676
private class MillBuildServer(
77-
initialEvaluator: Option[Evaluator],
7877
bspVersion: String,
7978
serverVersion: String,
8079
serverName: String,
@@ -97,7 +96,7 @@ private class MillBuildServer(
9796
private[this] var statePromise: Promise[State] = Promise[State]()
9897
var evaluatorOpt: Option[Evaluator] = None
9998
def evaluator = evaluatorOpt.get
100-
updateEvaluator(initialEvaluator)
99+
101100
def updateEvaluator(evaluator: Option[Evaluator]): Unit = {
102101
debug(s"Updating Evaluator: $evaluator")
103102
if (statePromise.isCompleted) statePromise = Promise[State]() // replace the promise

0 commit comments

Comments
 (0)