diff --git a/build.gradle b/build.gradle index af29ebd7a4..795093c273 100644 --- a/build.gradle +++ b/build.gradle @@ -86,6 +86,7 @@ configure(allprojects.findAll { (it.name != "framework-bom") } ) { project -> kotlinOptions { jvmTarget = "1.8" freeCompilerArgs = ["-Xjsr305=strict"] + allWarningsAsErrors = true } } compileTestKotlin { diff --git a/spring-messaging/src/main/kotlin/org/springframework/messaging/rsocket/RSocketRequesterExtensions.kt b/spring-messaging/src/main/kotlin/org/springframework/messaging/rsocket/RSocketRequesterExtensions.kt index 680eb08dee..028a346cce 100644 --- a/spring-messaging/src/main/kotlin/org/springframework/messaging/rsocket/RSocketRequesterExtensions.kt +++ b/spring-messaging/src/main/kotlin/org/springframework/messaging/rsocket/RSocketRequesterExtensions.kt @@ -17,6 +17,7 @@ package org.springframework.messaging.rsocket import io.rsocket.transport.ClientTransport +import kotlinx.coroutines.ExperimentalCoroutinesApi import kotlinx.coroutines.flow.Flow import kotlinx.coroutines.reactive.awaitFirstOrNull import kotlinx.coroutines.reactive.awaitSingle @@ -118,6 +119,7 @@ suspend inline fun RSocketRequester.ResponseSpec.retrieveAndAw * @author Sebastien Deleuze * @since 5.2 */ +@ExperimentalCoroutinesApi inline fun RSocketRequester.ResponseSpec.retrieveFlow(): Flow = retrieveFlux(object : ParameterizedTypeReference() {}).asFlow()