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 {