From 3ce48577b2413bd9b2c89541007a2c89433e2ae4 Mon Sep 17 00:00:00 2001 From: Sebastien Deleuze Date: Fri, 27 Sep 2019 19:27:46 +0200 Subject: [PATCH] DATACASS-689 - Remove @ExperimentalCoroutinesApi annotations. Original pull request: #165. --- .../data/cassandra/core/ReactiveSelectOperationExtensions.kt | 2 -- .../core/ReactiveSelectOperationExtensionsUnitTests.kt | 2 -- 2 files changed, 4 deletions(-) diff --git a/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/ReactiveSelectOperationExtensions.kt b/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/ReactiveSelectOperationExtensions.kt index 3e6ac79bf..17c6df698 100644 --- a/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/ReactiveSelectOperationExtensions.kt +++ b/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/ReactiveSelectOperationExtensions.kt @@ -15,7 +15,6 @@ */ package org.springframework.data.cassandra.core -import kotlinx.coroutines.ExperimentalCoroutinesApi import kotlinx.coroutines.flow.Flow import kotlinx.coroutines.reactive.asFlow import kotlinx.coroutines.reactive.awaitFirstOrNull @@ -117,6 +116,5 @@ suspend fun ReactiveSelectOperation.TerminatingSelect.awaitExists() * @author Sebastien Deleuze * @since 2.2 */ -@ExperimentalCoroutinesApi fun ReactiveSelectOperation.TerminatingSelect.flow(): Flow = all().asFlow() diff --git a/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/ReactiveSelectOperationExtensionsUnitTests.kt b/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/ReactiveSelectOperationExtensionsUnitTests.kt index b48a6b1bf..365b82060 100644 --- a/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/ReactiveSelectOperationExtensionsUnitTests.kt +++ b/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/ReactiveSelectOperationExtensionsUnitTests.kt @@ -18,7 +18,6 @@ package org.springframework.data.cassandra.core import io.mockk.every import io.mockk.mockk import io.mockk.verify -import kotlinx.coroutines.ExperimentalCoroutinesApi import kotlinx.coroutines.flow.toList import kotlinx.coroutines.runBlocking import org.assertj.core.api.Assertions.assertThat @@ -220,7 +219,6 @@ class ReactiveSelectOperationExtensionsUnitTests { } @Test // DATACASS-648 - @ExperimentalCoroutinesApi fun terminatingFindAllAsFlow() { val spec = mockk>()