enso-org/enso
1
1
Fork 0
mirror of https://github.com/enso-org/enso.git synced 2024-11-26 08:52:58 +03:00
Code Issues Projects Releases Wiki Activity

test: wait for FileManager init (#617)

Browse Source
This commit is contained in:
Dmitry Bushev 2020-03-23 21:37:11 +03:00 committed by GitHub
parent b6221e519a
commit 6f8d3b73bb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
engine/language-server/src/test/scala/org/enso/languageserver/websocket/BaseServerTest.scala
View File

@ -4,6 +4,8 @@ import java.nio.file.Files
import java.util.UUID import java.util.UUID
import akka.actor.{ActorRef, Props} import akka.actor.{ActorRef, Props}
import akka.pattern.ask
import akka.util.Timeout
import org.enso.jsonrpc.{ClientControllerFactory, Protocol} import org.enso.jsonrpc.{ClientControllerFactory, Protocol}
import org.enso.jsonrpc.test.JsonRpcServerTestKit import org.enso.jsonrpc.test.JsonRpcServerTestKit
import org.enso.languageserver.{LanguageProtocol, LanguageServer} import org.enso.languageserver.{LanguageProtocol, LanguageServer}
@ -19,6 +21,7 @@ import org.enso.languageserver.filemanager.{FileManager, FileSystem}
import org.enso.languageserver.protocol.{JsonRpc, ServerClientControllerFactory} import org.enso.languageserver.protocol.{JsonRpc, ServerClientControllerFactory}
import org.enso.languageserver.text.BufferRegistry import org.enso.languageserver.text.BufferRegistry
import scala.concurrent.Await
import scala.concurrent.duration._ import scala.concurrent.duration._
class BaseServerTest extends JsonRpcServerTestKit { class BaseServerTest extends JsonRpcServerTestKit {
@ -54,6 +57,7 @@ class BaseServerTest extends JsonRpcServerTestKit {
} }
private def getFileManager(): ActorRef = { private def getFileManager(): ActorRef = {
implicit val timeout = Timeout(10.seconds)
val zioExec = ZioExec(zio.Runtime.default) val zioExec = ZioExec(zio.Runtime.default)
val fileManager = val fileManager =
system.actorOf(FileManager.props(config, new FileSystem, zioExec)) system.actorOf(FileManager.props(config, new FileSystem, zioExec))
@ -61,9 +65,10 @@ class BaseServerTest extends JsonRpcServerTestKit {
// Windows. And it's always the first one that fails. I assume it happens // Windows. And it's always the first one that fails. I assume it happens
// due to a cold Zio executor. Here we send a few messages to warm up the // due to a cold Zio executor. Here we send a few messages to warm up the
// FileManager. // FileManager.
fileManager ! FileManagerProtocol.ExistsFile( val result = fileManager ? FileManagerProtocol.ExistsFile(
Path(testContentRootId, Vector()) Path(testContentRootId, Vector())
) )
Await.ready(result, Duration.Inf)
fileManager fileManager
} }
} }