Skip to content
This repository was archived by the owner on Mar 7, 2020. It is now read-only.

Commit 5e5a2a2

Browse files
authored
Merge pull request #5 from kptfh/master
test on LoggerReactiveHttpClient added
2 parents be58ad5 + 632d5b1 commit 5e5a2a2

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

feign-reactor-core/src/test/java/feign/reactor/LoggerTest.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,10 +33,12 @@
3333
import org.junit.Test;
3434
import org.mockito.ArgumentCaptor;
3535
import org.mockito.Mockito;
36+
import reactor.core.publisher.Mono;
3637
import java.util.List;
3738
import static com.github.tomakehurst.wiremock.client.WireMock.*;
3839
import static com.github.tomakehurst.wiremock.core.WireMockConfiguration.wireMockConfig;
3940
import static org.assertj.core.api.Assertions.assertThat;
41+
import static org.mockito.Mockito.never;
4042
import static org.mockito.Mockito.times;
4143
import static org.mockito.Mockito.when;
4244

@@ -74,9 +76,14 @@ public void shouldLog() throws Exception {
7476
.target(IcecreamServiceApi.class,
7577
"http://localhost:" + wireMockRule.port());
7678

77-
client.makeOrder(order).block();
79+
Mono<Bill> billMono = client.makeOrder(order);
7880

81+
// no logs before subscription
7982
ArgumentCaptor<LogEvent> argumentCaptor = ArgumentCaptor.forClass(LogEvent.class);
83+
Mockito.verify(appender, never()).append(argumentCaptor.capture());
84+
85+
billMono.block();
86+
8087
Mockito.verify(appender, times(7)).append(argumentCaptor.capture());
8188

8289
List<LogEvent> logEvents = argumentCaptor.getAllValues();

0 commit comments

Comments
 (0)