From 03d5498c22a9c8b05845d4f4aa67c4994654c1b2 Mon Sep 17 00:00:00 2001
From: Mark Paluch <mpaluch@pivotal.io>
Date: Thu, 23 Apr 2020 11:33:07 +0200
Subject: [PATCH] DATACMNS-1707 - Make CoroutineCrudRepository.deleteAll(Flow)
 suspended.

Delete by Flow is now suspended as the delete method completion is driven by the given Flow. To allow for synchronization, this method is suspended and awaits completion.
---
 .../data/repository/kotlin/CoroutineCrudRepository.kt           | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/kotlin/org/springframework/data/repository/kotlin/CoroutineCrudRepository.kt b/src/main/kotlin/org/springframework/data/repository/kotlin/CoroutineCrudRepository.kt
index d25d13164..7a7632536 100644
--- a/src/main/kotlin/org/springframework/data/repository/kotlin/CoroutineCrudRepository.kt
+++ b/src/main/kotlin/org/springframework/data/repository/kotlin/CoroutineCrudRepository.kt
@@ -147,7 +147,7 @@ interface CoroutineCrudRepository<T, ID> : Repository<T, ID> {
 	 * @param entityStream must not be null.
 	 * @throws IllegalArgumentException in case the given [entityStream][Flow] is null.
 	 */
-	fun <S : T> deleteAll(entityStream: Flow<S>)
+	suspend fun <S : T> deleteAll(entityStream: Flow<S>)
 
 	/**
 	 * Deletes all entities managed by the repository.