Spring/spring-data-cassandra
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATACASS-689 - Remove @ExperimentalCoroutinesApi annotations.

Browse Source 
Original pull request: #165.
This commit is contained in:
Sebastien Deleuze
2019-09-27 19:27:46 +02:00
committed by Mark Paluch
parent 75f4d76324
commit 3ce48577b2
2 changed files with 0 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/ReactiveSelectOperationExtensions.kt
View File

@@ -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 <T : Any> ReactiveSelectOperation.TerminatingSelect<T>.awaitExists()
* @author Sebastien Deleuze
* @since 2.2
*/
@ExperimentalCoroutinesApi
fun <T : Any> ReactiveSelectOperation.TerminatingSelect<T>.flow(): Flow<T> =
all().asFlow()

2
spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/ReactiveSelectOperationExtensionsUnitTests.kt
View File

@@ -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<ReactiveSelectOperation.TerminatingSelect<String>>()