mindol1004/spring-soap
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

JAVA-8405: reducing logging for tutorials-build-job

Browse Source
This commit is contained in:
chaos2418
2021-11-18 11:19:23 +05:30
parent 4ca8e7ef23
commit a62c0f3c8b
81 changed files with 715 additions and 126 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-5-reactive-2/src/test/java/com/baeldung/backpressure/BackpressureUnitTest.java
View File

@@ -1,21 +1,25 @@
package com.baeldung.backpressure;
import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import reactor.core.publisher.BaseSubscriber;
import reactor.core.publisher.Flux;
import reactor.test.StepVerifier;
public class BackpressureUnitTest {
private static final Logger LOGGER = LoggerFactory.getLogger(BackpressureUnitTest.class);
@Test
public void whenLimitRateSet_thenSplitIntoChunks() throws InterruptedException {
Flux<Integer> limit = Flux.range(1, 25);
limit.limitRate(10);
limit.subscribe(
value -> System.out.println(value),
value -> LOGGER.debug(String.valueOf(value)),
err -> err.printStackTrace(),
() -> System.out.println("Finished!!"),
() -> LOGGER.debug("Finished!!"),
subscription -> subscription.request(15)
);
@@ -34,12 +38,12 @@ public class BackpressureUnitTest {
Flux<Integer> request = Flux.range(1, 50);
request.subscribe(
System.out::println,
integer -> LOGGER.debug(String.valueOf(integer)),
err -> err.printStackTrace(),
() -> System.out.println("All 50 items have been successfully processed!!!"),
() -> LOGGER.debug("All 50 items have been successfully processed!!!"),
subscription -> {
for (int i = 0; i < 5; i++) {
System.out.println("Requesting the next 10 elements!!!");
LOGGER.debug("Requesting the next 10 elements!!!");
subscription.request(10);
}
}
@@ -68,7 +72,7 @@ public class BackpressureUnitTest {
@Override
protected void hookOnNext(Integer value) {
request(3);
System.out.println(value);
LOGGER.debug(String.valueOf(value));
cancel();
}
});