Skip to content

Commit bcf11e8

Browse files
committed
Replace Reactive awaitSingle() usages by the Mono variant
Closes gh-31127
1 parent af03fa7 commit bcf11e8

File tree

10 files changed

+10
-10
lines changed

10 files changed

+10
-10
lines changed

spring-messaging/src/main/kotlin/org/springframework/messaging/rsocket/RSocketRequesterExtensions.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ package org.springframework.messaging.rsocket
1919
import io.rsocket.transport.ClientTransport
2020
import kotlinx.coroutines.flow.Flow
2121
import kotlinx.coroutines.reactive.asFlow
22-
import kotlinx.coroutines.reactive.awaitSingle
22+
import kotlinx.coroutines.reactor.awaitSingle
2323
import kotlinx.coroutines.reactor.awaitSingleOrNull
2424
import org.reactivestreams.Publisher
2525
import org.springframework.core.ParameterizedTypeReference

spring-r2dbc/src/main/kotlin/org/springframework/r2dbc/core/UpdatedRowsFetchSpecExtensions.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616

1717
package org.springframework.r2dbc.core
1818

19-
import kotlinx.coroutines.reactive.awaitSingle
19+
import kotlinx.coroutines.reactor.awaitSingle
2020

2121
/**
2222
* Coroutines variant of [UpdatedRowsFetchSpec.rowsUpdated].

spring-web/src/main/kotlin/org/springframework/web/server/ServerWebExchangeExtensions.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
package org.springframework.web.server
1818

1919
import kotlinx.coroutines.Dispatchers
20-
import kotlinx.coroutines.reactive.awaitSingle
20+
import kotlinx.coroutines.reactor.awaitSingle
2121
import kotlinx.coroutines.reactor.mono
2222
import org.springframework.http.codec.multipart.Part
2323
import org.springframework.util.MultiValueMap

spring-webflux/src/main/kotlin/org/springframework/web/reactive/function/client/ClientResponseExtensions.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ package org.springframework.web.reactive.function.client
1818

1919
import kotlinx.coroutines.flow.Flow
2020
import kotlinx.coroutines.reactor.awaitSingleOrNull
21-
import kotlinx.coroutines.reactive.awaitSingle
21+
import kotlinx.coroutines.reactor.awaitSingle
2222
import kotlinx.coroutines.reactive.asFlow
2323
import org.springframework.core.ParameterizedTypeReference
2424
import org.springframework.http.ResponseEntity

spring-webflux/src/main/kotlin/org/springframework/web/reactive/function/client/WebClientExtensions.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ package org.springframework.web.reactive.function.client
1919
import kotlinx.coroutines.Dispatchers
2020
import kotlinx.coroutines.flow.Flow
2121
import kotlinx.coroutines.reactive.asFlow
22-
import kotlinx.coroutines.reactive.awaitSingle
22+
import kotlinx.coroutines.reactor.awaitSingle
2323
import kotlinx.coroutines.reactor.awaitSingleOrNull
2424
import kotlinx.coroutines.reactor.asFlux
2525
import kotlinx.coroutines.reactor.mono

spring-webflux/src/main/kotlin/org/springframework/web/reactive/function/server/CoRouterFunctionDsl.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
package org.springframework.web.reactive.function.server
1818

1919
import kotlinx.coroutines.Dispatchers
20-
import kotlinx.coroutines.reactive.awaitSingle
20+
import kotlinx.coroutines.reactor.awaitSingle
2121
import kotlinx.coroutines.reactor.mono
2222
import org.springframework.core.io.Resource
2323
import org.springframework.http.HttpMethod

spring-webflux/src/main/kotlin/org/springframework/web/reactive/function/server/RenderingResponseExtensions.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616

1717
package org.springframework.web.reactive.function.server
1818

19-
import kotlinx.coroutines.reactive.awaitSingle
19+
import kotlinx.coroutines.reactor.awaitSingle
2020

2121
/**
2222
* Coroutines variant of [RenderingResponse.Builder.build].

spring-webflux/src/main/kotlin/org/springframework/web/reactive/function/server/ServerRequestExtensions.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ package org.springframework.web.reactive.function.server
1818

1919
import kotlinx.coroutines.flow.Flow
2020
import kotlinx.coroutines.reactor.awaitSingleOrNull
21-
import kotlinx.coroutines.reactive.awaitSingle
21+
import kotlinx.coroutines.reactor.awaitSingle
2222
import kotlinx.coroutines.reactive.asFlow
2323
import org.springframework.core.ParameterizedTypeReference
2424
import org.springframework.http.MediaType

spring-webflux/src/main/kotlin/org/springframework/web/reactive/function/server/ServerResponseExtensions.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
package org.springframework.web.reactive.function.server
1818

1919
import kotlinx.coroutines.flow.Flow
20-
import kotlinx.coroutines.reactive.awaitSingle
20+
import kotlinx.coroutines.reactor.awaitSingle
2121
import org.reactivestreams.Publisher
2222
import org.springframework.core.ParameterizedTypeReference
2323
import org.springframework.http.MediaType

spring-webflux/src/main/kotlin/org/springframework/web/reactive/server/ServerWebExchangeExtensions.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
package org.springframework.web.reactive.server
1818

1919
import kotlinx.coroutines.Dispatchers
20-
import kotlinx.coroutines.reactive.awaitSingle
20+
import kotlinx.coroutines.reactor.awaitSingle
2121
import kotlinx.coroutines.reactor.mono
2222
import org.springframework.http.codec.multipart.Part
2323
import org.springframework.util.MultiValueMap

0 commit comments

Comments
 (0)