From f1c093715078f3c3dbf6b60826fa3fd68f85f532 Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Thu, 12 Sep 2019 10:17:46 +0200 Subject: [PATCH] =?UTF-8?q?Return=20Unit=20from=20ReactiveVaultOperations.?= =?UTF-8?q?awaitDelete(=E2=80=A6).?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit See gh-472. --- .../vault/core/ReactiveVaultOperationsExtensions.kt | 5 +++-- .../vault/core/ReactiveVaultOperationsExtensionsTests.kt | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/spring-vault-core/src/main/kotlin/org/springframework/vault/core/ReactiveVaultOperationsExtensions.kt b/spring-vault-core/src/main/kotlin/org/springframework/vault/core/ReactiveVaultOperationsExtensions.kt index c9c72649..89db7bb3 100644 --- a/spring-vault-core/src/main/kotlin/org/springframework/vault/core/ReactiveVaultOperationsExtensions.kt +++ b/spring-vault-core/src/main/kotlin/org/springframework/vault/core/ReactiveVaultOperationsExtensions.kt @@ -86,5 +86,6 @@ suspend fun ReactiveVaultOperations.awaitWrite(path: String, body: Any): VaultRe * @author Mark Paluch * @since 2.2 */ -suspend fun ReactiveVaultOperations.awaitDelete(path: String) = delete(path).awaitFirstOrNull() - +suspend fun ReactiveVaultOperations.awaitDelete(path: String) { + delete(path).awaitFirstOrNull() +} diff --git a/spring-vault-core/src/test/kotlin/org/springframework/vault/core/ReactiveVaultOperationsExtensionsTests.kt b/spring-vault-core/src/test/kotlin/org/springframework/vault/core/ReactiveVaultOperationsExtensionsTests.kt index 1c859893..d82b9986 100644 --- a/spring-vault-core/src/test/kotlin/org/springframework/vault/core/ReactiveVaultOperationsExtensionsTests.kt +++ b/spring-vault-core/src/test/kotlin/org/springframework/vault/core/ReactiveVaultOperationsExtensionsTests.kt @@ -132,7 +132,7 @@ class ReactiveVaultOperationsExtensionsTests { every { operation.delete("path") } returns Mono.empty() runBlocking { - assertThat(operation.awaitDelete("path")).isNull() + assertThat(operation.awaitDelete("path")).isEqualTo(Unit) } verify {