mindol1004/spring-data-mongodb
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

DATAMONGO-2380 - Remove @ExperimentalCoroutinesApi annotations.

Browse Source 
Original pull request: #795.
This commit is contained in:
Sebastien Deleuze
2019-09-27 19:13:48 +02:00
committed by Mark Paluch
parent 48034a348d
commit 928134c6e1
12 changed files with 0 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-data-mongodb/src/main/kotlin/org/springframework/data/mongodb/core/ReactiveAggregationOperationExtensions.kt
View File

@@ -15,7 +15,6 @@
*/
package org.springframework.data.mongodb.core
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.reactive.asFlow
import kotlin.reflect.KClass
@@ -45,6 +44,5 @@ inline fun <reified T : Any> ReactiveAggregationOperation.aggregateAndReturn():
* @author Sebastien Deleuze
* @since 2.2
*/
@ExperimentalCoroutinesApi
fun <T : Any> ReactiveAggregationOperation.TerminatingAggregationOperation<T>.flow(): Flow<T> =
all().asFlow()

2
spring-data-mongodb/src/main/kotlin/org/springframework/data/mongodb/core/ReactiveChangeStreamOperationExtensions.kt
View File

@@ -15,7 +15,6 @@
*/
package org.springframework.data.mongodb.core
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.reactive.asFlow
@@ -44,7 +43,6 @@ inline fun <reified T : Any> ReactiveChangeStreamOperation.ChangeStreamWithFilte
* @author Sebastien Deleuze
* @since 2.2
*/
@ExperimentalCoroutinesApi
fun <T : Any> ReactiveChangeStreamOperation.TerminatingChangeStream<T>.flow(): Flow<ChangeStreamEvent<T>> =
listen().asFlow()

5
spring-data-mongodb/src/main/kotlin/org/springframework/data/mongodb/core/ReactiveFindOperationExtensions.kt
View File

@@ -15,7 +15,6 @@
*/
package org.springframework.data.mongodb.core
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.reactive.asFlow
import kotlinx.coroutines.reactive.awaitFirstOrNull
@@ -139,7 +138,6 @@ suspend fun <T : Any> ReactiveFindOperation.TerminatingFind<T>.awaitExists(): Bo
*
* @author Sebastien Deleuze
*/
@ExperimentalCoroutinesApi
fun <T : Any> ReactiveFindOperation.TerminatingFind<T>.flow(): Flow<T> =
all().asFlow()
@@ -148,7 +146,6 @@ fun <T : Any> ReactiveFindOperation.TerminatingFind<T>.flow(): Flow<T> =
*
* @author Sebastien Deleuze
*/
@ExperimentalCoroutinesApi
fun <T : Any> ReactiveFindOperation.TerminatingFind<T>.tailAsFlow(): Flow<T> =
tail().asFlow()
@@ -157,7 +154,6 @@ fun <T : Any> ReactiveFindOperation.TerminatingFind<T>.tailAsFlow(): Flow<T> =
*
* @author Sebastien Deleuze
*/
@ExperimentalCoroutinesApi
fun <T : Any> ReactiveFindOperation.TerminatingFindNear<T>.flow(): Flow<GeoResult<T>> =
all().asFlow()
@@ -167,6 +163,5 @@ fun <T : Any> ReactiveFindOperation.TerminatingFindNear<T>.flow(): Flow<GeoResul
* @author Sebastien Deleuze
* @since 2.2
*/
@ExperimentalCoroutinesApi
fun <T : Any> ReactiveFindOperation.TerminatingDistinct<T>.flow(): Flow<T> =
all().asFlow()

2
spring-data-mongodb/src/main/kotlin/org/springframework/data/mongodb/core/ReactiveInsertOperationExtensions.kt
View File

@@ -15,7 +15,6 @@
*/
package org.springframework.data.mongodb.core
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.reactive.asFlow
import kotlinx.coroutines.reactive.awaitSingle
@@ -56,6 +55,5 @@ suspend inline fun <reified T: Any> ReactiveInsertOperation.TerminatingInsert<T>
* @author Sebastien Deleuze
* @since 2.2
*/
@ExperimentalCoroutinesApi
fun <T : Any> ReactiveInsertOperation.TerminatingInsert<T>.flow(objects: Collection<T>): Flow<T> =
all(objects).asFlow()

2
spring-data-mongodb/src/main/kotlin/org/springframework/data/mongodb/core/ReactiveMapReduceOperationExtensions.kt
View File

@@ -15,7 +15,6 @@
*/
package org.springframework.data.mongodb.core
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.reactive.asFlow
import kotlin.reflect.KClass
@@ -65,6 +64,5 @@ inline fun <reified T : Any> ReactiveMapReduceOperation.MapReduceWithProjection<
* @author Sebastien Deleuze
* @since 2.2
*/
@ExperimentalCoroutinesApi
fun <T : Any> ReactiveMapReduceOperation.TerminatingMapReduce<T>.flow(): Flow<T> =
all().asFlow()

2
spring-data-mongodb/src/main/kotlin/org/springframework/data/mongodb/core/ReactiveRemoveOperationExtensions.kt
View File

@@ -16,7 +16,6 @@
package org.springframework.data.mongodb.core
import com.mongodb.client.result.DeleteResult
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.reactive.asFlow
import kotlinx.coroutines.reactive.awaitSingle
@@ -57,6 +56,5 @@ suspend fun <T : Any> ReactiveRemoveOperation.TerminatingRemove<T>.allAndAwait()
* @author Sebastien Deleuze
* @since 2.2
*/
@ExperimentalCoroutinesApi
fun <T : Any> ReactiveRemoveOperation.TerminatingRemove<T>.findAndRemoveAsFlow(): Flow<T> =
findAndRemove().asFlow()

2
spring-data-mongodb/src/test/kotlin/org/springframework/data/mongodb/core/ReactiveAggregationOperationExtensionsTests.kt
View File

@@ -19,7 +19,6 @@ import example.first.First
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
@@ -50,7 +49,6 @@ class ReactiveAggregationOperationExtensionsTests {
}
@Test // DATAMONGO-2255
@ExperimentalCoroutinesApi
fun terminatingAggregationOperationAllAsFlow() {
val spec = mockk<ReactiveAggregationOperation.TerminatingAggregationOperation<String>>()

2
spring-data-mongodb/src/test/kotlin/org/springframework/data/mongodb/core/ReactiveChangeStreamOperationExtensionsTests.kt
View File

@@ -19,7 +19,6 @@ import example.first.First
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
@@ -44,7 +43,6 @@ class ReactiveChangeStreamOperationExtensionsTests {
}
@Test // DATAMONGO-2089
@ExperimentalCoroutinesApi
fun `TerminatingChangeStream#listen() flow extension`() {
val doc1 = mockk<ChangeStreamEvent<Document>>()

2
spring-data-mongodb/src/test/kotlin/org/springframework/data/mongodb/core/ReactiveFindOperationExtensionsTests.kt
View File

@@ -19,7 +19,6 @@ import example.first.First
import io.mockk.every
import io.mockk.mockk
import io.mockk.verify
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.take
import kotlinx.coroutines.flow.toList
import kotlinx.coroutines.runBlocking
@@ -35,7 +34,6 @@ import reactor.core.publisher.Mono
* @author Mark Paluch
* @author Sebastien Deleuze
*/
@ExperimentalCoroutinesApi
class ReactiveFindOperationExtensionsTests {
val operation = mockk<ReactiveFindOperation>(relaxed = true)

2
spring-data-mongodb/src/test/kotlin/org/springframework/data/mongodb/core/ReactiveInsertOperationExtensionsTests.kt
View File

@@ -19,7 +19,6 @@ import example.first.First
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
@@ -66,7 +65,6 @@ class ReactiveInsertOperationExtensionsTests {
}
@Test // DATAMONGO-2255
@ExperimentalCoroutinesApi
fun terminatingInsertAllAsFlow() {
val insert = mockk<ReactiveInsertOperation.TerminatingInsert<String>>()

2
spring-data-mongodb/src/test/kotlin/org/springframework/data/mongodb/core/ReactiveMapReduceOperationExtensionsTests.kt
View File

@@ -19,7 +19,6 @@ import example.first.First
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
@@ -67,7 +66,6 @@ class ReactiveMapReduceOperationExtensionsTests {
}
@Test // DATAMONGO-2255
@ExperimentalCoroutinesApi
fun terminatingMapReduceAllAsFlow() {
val spec = mockk<ReactiveMapReduceOperation.TerminatingMapReduce<String>>()

2
spring-data-mongodb/src/test/kotlin/org/springframework/data/mongodb/core/ReactiveRemoveOperationExtensionsTests.kt
View File

@@ -20,7 +20,6 @@ import example.first.First
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
@@ -68,7 +67,6 @@ class ReactiveRemoveOperationExtensionsTests {
}
@Test // DATAMONGO-2255
@ExperimentalCoroutinesApi
fun terminatingRemoveFindAndRemoveAsFlow() {
val spec = mockk<ReactiveRemoveOperation.TerminatingRemove<String>>()