We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b8433e5 commit 21b4361Copy full SHA for 21b4361
src/test/java/com/github/phantomthief/test/MultiThreadQueueTriggerTest.java
@@ -53,7 +53,7 @@ public void test2() throws InterruptedException {
53
BufferTrigger<String> buffer = BufferTrigger.<String> batchBlocking() //
54
.batchConsumerSize(3) //
55
.setConsumerEx(this::delay) //
56
- .consumePeriod(10, MILLISECONDS) //
+ .linger(10, MILLISECONDS) //
57
.build();
58
Set<String> allData = synchronizedSet(new HashSet<>());
59
deal = synchronizedSet(new HashSet<>());
0 commit comments