projects
/
demos
/
kafka
/
wordcount
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
counter: 1.2.15 - Inlined the asserting ``Consumer``s
[demos/kafka/wordcount]
/
src
/
test
/
java
/
de
/
juplo
/
kafka
/
wordcount
/
counter
/
CounterApplicationIT.java
diff --git
a/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
b/src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
index
a53ffc8
..
9995ce7
100644
(file)
--- a/
src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
+++ b/
src/test/java/de/juplo/kafka/wordcount/counter/CounterApplicationIT.java
@@
-91,7
+91,8
@@
public class CounterApplicationIT
{
await("Expected number of messages")
.atMost(Duration.ofSeconds(5))
{
await("Expected number of messages")
.atMost(Duration.ofSeconds(5))
- .untilAsserted(() -> consumer.enforceAssertion(TestData.expectedNumberOfMessagesForWordAssertion()));
+ .untilAsserted(() -> consumer.enforceAssertion(
+ receivedMessages -> TestData.assertExpectedNumberOfMessagesForWord(receivedMessages)));
}
@DisplayName("Await the expected output messages")
}
@DisplayName("Await the expected output messages")
@@
-100,7
+101,8
@@
public class CounterApplicationIT
{
await("Expected messages")
.atMost(Duration.ofSeconds(10))
{
await("Expected messages")
.atMost(Duration.ofSeconds(10))
- .untilAsserted(() -> consumer.enforceAssertion(TestData.expectedMessagesAssertion()));
+ .untilAsserted(() -> consumer.enforceAssertion(
+ receivedMessages -> TestData.assertExpectedMessages(receivedMessages)));
}
@DisplayName("Await the expected final output messages")
}
@DisplayName("Await the expected final output messages")
@@
-109,7
+111,8
@@
public class CounterApplicationIT
{
await("Expected final output messages")
.atMost(Duration.ofSeconds(5))
{
await("Expected final output messages")
.atMost(Duration.ofSeconds(5))
- .untilAsserted(() -> consumer.enforceAssertion(TestData.expectedLastMessagesForWordAssertion()));
+ .untilAsserted(() -> consumer.enforceAssertion(
+ receivedMessages -> TestData.assertExpectedLastMessagesForWord(receivedMessages)));
}
@DisplayName("Await the expected state in the state-store")
}
@DisplayName("Await the expected state in the state-store")