File tree Expand file tree Collapse file tree
src/test/kotlin/eu/openanalytics/shinyproxyoperator/helpers Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -22,11 +22,14 @@ package eu.openanalytics.shinyproxyoperator.helpers
2222
2323import eu.openanalytics.shinyproxyoperator.IEventController
2424import eu.openanalytics.shinyproxyoperator.model.ShinyProxyInstance
25+ import io.github.oshai.kotlinlogging.KotlinLogging
2526import kotlinx.coroutines.CompletableDeferred
2627
2728
2829class AwaitableEvenController : IEventController {
2930
31+ private val logger = KotlinLogging .logger { }
32+
3033 private val listeners = Listener <String >()
3134 private val deleteListeners = Listener <Unit >()
3235 private val newInstanceListeners = Listener <ShinyProxyInstance >()
@@ -42,11 +45,13 @@ class AwaitableEvenController : IEventController {
4245 }
4346
4447 suspend fun waitForNewInstance (hash : String , revision : Int = 0): ShinyProxyInstance {
48+ logger.info { " --> waiting for NewInstance: hash: $hash , revision: $revision " }
4549 return newInstanceListeners.add(hash, revision).awaitWithTimeout()
4650 }
4751
4852 override fun createNewInstanceEvent (shinyProxyInstance : ShinyProxyInstance ) {
4953 delegate.createNewInstanceEvent(shinyProxyInstance)
54+ logger.info { " <-- event NewInstance: hash: ${shinyProxyInstance.hashOfSpec} , revision: ${shinyProxyInstance.revision} " }
5055 newInstanceListeners.complete(shinyProxyInstance, shinyProxyInstance)
5156 }
5257
You can’t perform that action at this time.
0 commit comments