Skip to content

Commit efdfe9a

Browse files
committed
Minor Javadoc update
1 parent 1653a32 commit efdfe9a

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

spring-web/src/test/java/org/springframework/http/server/reactive/AbstractHttpHandlerIntegrationTests.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,14 @@ public void tearDown() throws Exception {
7979
/**
8080
* Return an interval stream of with n number of ticks and buffer the
8181
* emissions to avoid back pressure failures (e.g. on slow CI server).
82+
*
83+
* <p>Use this method as follows:
84+
* <ul>
85+
* <li>Tests that verify N number of items followed by verifyOnComplete()
86+
* should set the number of emissions to N.
87+
* <li>Tests that verify N number of items followed by thenCancel() should
88+
* set the number of buffered to an arbitrary number greater than N.
89+
* </ul>
8290
*/
8391
public static Flux<Long> interval(Duration period, int count) {
8492
return Flux.interval(period).take(count).onBackpressureBuffer(2);

0 commit comments

Comments
 (0)