We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9b33b0a commit d587a66Copy full SHA for d587a66
spring-messaging/src/test/kotlin/org/springframework/messaging/rsocket/RSocketRequesterExtensionsTests.kt
@@ -18,6 +18,7 @@ package org.springframework.messaging.rsocket
18
19
import io.mockk.every
20
import io.mockk.mockk
21
+import kotlinx.coroutines.ExperimentalCoroutinesApi
22
import kotlinx.coroutines.flow.Flow
23
import kotlinx.coroutines.flow.toList
24
import kotlinx.coroutines.runBlocking
@@ -125,6 +126,7 @@ class RSocketRequesterExtensionsTests {
125
126
}
127
128
@Test
129
+ @ExperimentalCoroutinesApi
130
fun retrieveFlow() {
131
val responseSpec = mockk<RSocketRequester.ResponseSpec>()
132
every { responseSpec.retrieveFlux(match<ParameterizedTypeReference<*>>(stringTypeRefMatcher)) } returns Flux.just("foo", "bar")
0 commit comments