From e595ad799a43f5b19b70a8fd7dc0841885c2c182 Mon Sep 17 00:00:00 2001 From: Nikita Barkov Date: Wed, 17 Jul 2024 22:02:23 +0200 Subject: [PATCH] [perf_tests]Cancel serverJob after each test, not only after all tests GitOrigin-RevId: bddc72f5d6c48cde20d8c59a6542fb0f37a3323e --- .../intellij/tools/ide/starter/bus/shared/SharedEventsFlow.kt | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/plugins/performanceTesting/event-bus/src/com/intellij/tools/ide/starter/bus/shared/SharedEventsFlow.kt b/plugins/performanceTesting/event-bus/src/com/intellij/tools/ide/starter/bus/shared/SharedEventsFlow.kt index c57c96320f14..0a443ba5a369 100644 --- a/plugins/performanceTesting/event-bus/src/com/intellij/tools/ide/starter/bus/shared/SharedEventsFlow.kt +++ b/plugins/performanceTesting/event-bus/src/com/intellij/tools/ide/starter/bus/shared/SharedEventsFlow.kt @@ -24,8 +24,6 @@ class SharedEventsFlow( private var serverJob: Job? = null fun endServerProcess() { - runBlocking { serverJob?.cancelAndJoin() } - serverJob = null client.endServerProcess() } @@ -84,6 +82,8 @@ class SharedEventsFlow( } override fun unsubscribeAll() { + runBlocking { serverJob?.cancelAndJoin() } + serverJob = null processedEvents.clear() client.clear() }