Bump up dependencies. (#27586)
* Bump up dependencies. * revert sslConfigVersion and sigarLoader. * only used in tests. * Bump up dependencies.
This commit is contained in:
parent
9a9e21a62b
commit
9aa0e593b0
7 changed files with 41 additions and 42 deletions
|
|
@ -144,8 +144,7 @@ public class TwitterStreamQuickstartDocTest extends AbstractJavaTest {
|
|||
}
|
||||
|
||||
public Set<Hashtag> hashtags() {
|
||||
return Arrays.asList(body.split(" "))
|
||||
.stream()
|
||||
return Arrays.asList(body.split(" ")).stream()
|
||||
.filter(a -> a.startsWith("#"))
|
||||
.map(a -> new Hashtag(a))
|
||||
.collect(Collectors.toSet());
|
||||
|
|
|
|||
|
|
@ -142,8 +142,7 @@ public class RecipeGlobalRateLimit extends RecipeTest {
|
|||
@Override
|
||||
public void postStop() {
|
||||
replenishTimer.cancel();
|
||||
waitQueue
|
||||
.stream()
|
||||
waitQueue.stream()
|
||||
.forEach(
|
||||
ref -> {
|
||||
ref.tell(
|
||||
|
|
|
|||
|
|
@ -101,8 +101,7 @@ public class RecipeMultiGroupByTest extends RecipeTest {
|
|||
// Create a (Msg, Topic) pair for each of the topics
|
||||
|
||||
// the message belongs to
|
||||
return topicsForMessage
|
||||
.stream()
|
||||
return topicsForMessage.stream()
|
||||
.map(topic -> new Pair<Message, Topic>(msg, topic))
|
||||
.collect(toList());
|
||||
});
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue