From 177f8f996aa2d359cdf2767381063bd492a53792 Mon Sep 17 00:00:00 2001 From: Pavel Kunyavskiy Date: Sun, 27 Oct 2024 10:00:35 +0100 Subject: [PATCH] Remove commented debug --- .../cds/adapters/impl/RemoveFrozenSubmissionsAdapter.kt | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/cds/core/src/main/kotlin/org/icpclive/cds/adapters/impl/RemoveFrozenSubmissionsAdapter.kt b/src/cds/core/src/main/kotlin/org/icpclive/cds/adapters/impl/RemoveFrozenSubmissionsAdapter.kt index 462414a1..91ea9ce4 100644 --- a/src/cds/core/src/main/kotlin/org/icpclive/cds/adapters/impl/RemoveFrozenSubmissionsAdapter.kt +++ b/src/cds/core/src/main/kotlin/org/icpclive/cds/adapters/impl/RemoveFrozenSubmissionsAdapter.kt @@ -12,7 +12,6 @@ internal fun Flow.processByTimeCut( process: (RunInfo) -> RunInfo ): Flow = contestState().transform { suspend fun emit(info: RunInfo, cut: Duration) { -// println("${info.id} ${info.time} ${info.result} $cut ${it.lastEvent}") if (info.time > cut) { emit(RunUpdate(process(info))) } else { @@ -31,13 +30,12 @@ internal fun Flow.processByTimeCut( if (oldCut != newCut) { it.runsAfterEvent.values .filter { run -> (run.time > oldCut) != (run.time > newCut) } -// .also { println("Updated runs: ${it.map { run -> run.id }}")} .forEach { run -> emit(run, newCut) } } } is CommentaryMessagesUpdate -> emit(it.lastEvent) } -}.onEach { /* if (it is RunUpdate) println("${it.newInfo.id} ${it.newInfo.time} ${it.newInfo.result}") */ } +} internal fun removeFrozenSubmissionsResults(flow: Flow): Flow = flow.processByTimeCut(