From b52786618a19cfa5129321434973dce3c8bb7a6c Mon Sep 17 00:00:00 2001 From: darken Date: Thu, 30 Jan 2025 17:38:10 +0100 Subject: [PATCH] Fix `FlowShellTest` --- .../src/test/java/eu/darken/flowshell/core/FlowShellTest.kt | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/app-common-shell/src/test/java/eu/darken/flowshell/core/FlowShellTest.kt b/app-common-shell/src/test/java/eu/darken/flowshell/core/FlowShellTest.kt index d34d3a418..e4bc86316 100644 --- a/app-common-shell/src/test/java/eu/darken/flowshell/core/FlowShellTest.kt +++ b/app-common-shell/src/test/java/eu/darken/flowshell/core/FlowShellTest.kt @@ -44,8 +44,8 @@ class FlowShellTest : BaseTest() { val rows = (1..10L) shell.session.flowOn(Dispatchers.IO).collect { session -> - session.output.onEach { output.add(it) }.launchIn(this) - session.error.onEach { errors.add(it) }.launchIn(this) + val outputJob = session.output.onEach { output.add(it) }.launchIn(this) + val errorJob = session.error.onEach { errors.add(it) }.launchIn(this) rows.forEach { session.write("echo test $it") session.write("echo error $it 1>&2") @@ -54,6 +54,8 @@ class FlowShellTest : BaseTest() { session.close() session.isAlive() shouldBe false session.waitFor() shouldBe FlowProcess.ExitCode.OK + outputJob.join() + errorJob.join() } output shouldBe rows.map { "test $it" }