|
|
|
@ -23,7 +23,6 @@ import kotlinx.coroutines.flow.toList
@@ -23,7 +23,6 @@ import kotlinx.coroutines.flow.toList
|
|
|
|
|
import kotlinx.coroutines.runBlocking |
|
|
|
|
import org.assertj.core.api.Assertions.assertThat |
|
|
|
|
import org.junit.jupiter.api.Test |
|
|
|
|
import org.mockito.ArgumentMatchers.anyInt |
|
|
|
|
import org.reactivestreams.Publisher |
|
|
|
|
import org.springframework.core.ParameterizedTypeReference |
|
|
|
|
import reactor.core.publisher.Flux |
|
|
|
@ -54,7 +53,7 @@ class RSocketRequesterExtensionsTests {
@@ -54,7 +53,7 @@ class RSocketRequesterExtensionsTests {
|
|
|
|
|
val host = "127.0.0.1" |
|
|
|
|
val requester = mockk<RSocketRequester>() |
|
|
|
|
val builder = mockk<RSocketRequester.Builder>() |
|
|
|
|
every { builder.connectTcp(host, anyInt()) } returns Mono.just(requester) |
|
|
|
|
every { builder.connectTcp(host, any()) } returns Mono.just(requester) |
|
|
|
|
runBlocking { |
|
|
|
|
assertThat(builder.connectTcpAndAwait(host, 0)).isEqualTo(requester) |
|
|
|
|
} |
|
|
|
|