|
|
|
|
@ -75,7 +75,7 @@ public class DefaultRSocketRequesterBuilderTests {
@@ -75,7 +75,7 @@ public class DefaultRSocketRequesterBuilderTests {
|
|
|
|
|
@BeforeEach |
|
|
|
|
public void setup() { |
|
|
|
|
this.transport = mock(ClientTransport.class); |
|
|
|
|
given(this.transport.connect(anyInt())).willReturn(Mono.just(this.connection)); |
|
|
|
|
given(this.transport.connect()).willReturn(Mono.just(this.connection)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@ -106,7 +106,7 @@ public class DefaultRSocketRequesterBuilderTests {
@@ -106,7 +106,7 @@ public class DefaultRSocketRequesterBuilderTests {
|
|
|
|
|
|
|
|
|
|
// RSocketStrategies and RSocketConnector configurers should have been called
|
|
|
|
|
|
|
|
|
|
verify(this.transport).connect(anyInt()); |
|
|
|
|
verify(this.transport).connect(); |
|
|
|
|
verify(strategiesConfigurer).accept(any(RSocketStrategies.Builder.class)); |
|
|
|
|
verify(factoryConfigurer).configure(any(io.rsocket.RSocketFactory.ClientRSocketFactory.class)); |
|
|
|
|
assertThat(this.connectorConfigurer.connector()).isNotNull(); |
|
|
|
|
|