Skip to content
This repository was archived by the owner on Mar 16, 2022. It is now read-only.

Report last error on waiting for TCK implementation start #526

Merged
pvlugter merged 1 commit into from
Feb 2, 2021
Merged

Report last error on waiting for TCK implementation start #526

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 9 additions & 3 deletions testkit/src/main/scala/io/cloudstate/testkit/discovery/InterceptEntityDiscovery.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ import io.cloudstate.testkit.InterceptService.InterceptorContext

import scala.concurrent.duration.FiniteDuration
import scala.concurrent.{Await, Future}
import scala.util.{Failure, Success}
import scala.util.{Failure, Success, Try}

final class InterceptEntityDiscovery(context: InterceptorContext) {
import InterceptEntityDiscovery._
Expand Down Expand Up @@ -88,7 +88,13 @@ object InterceptEntityDiscovery {

def expectOnline(context: InterceptorContext, timeout: FiniteDuration): Unit = {
val client = EntityDiscoveryClient(context.clientSettings)(context.system)
try TestKit.awaitCond(Await.ready(client.discover(testProxyInfo), timeout).value.get.isSuccess, timeout)
finally client.close()
try {
var discovery: Try[EntitySpec] = null
if (!TestKit.awaitCond({
discovery = Await.ready(client.discover(testProxyInfo), timeout).value.get
discovery.isSuccess
}, timeout, noThrow = true))
throw new AssertionError(s"No discovery after $timeout, last error: ${discovery.failed.get.getMessage}")
} finally client.close()
}
}