From f8fa00185f564f9565859ff648b549b7fbf5470f Mon Sep 17 00:00:00 2001
From: Nik Everett <nik9000@gmail.com>
Date: Thu, 24 Sep 2015 13:53:05 -0400
Subject: [PATCH] Better format some stream usage

---
 .../elasticsearch/cluster/block/ClusterBlocks.java   | 12 +++++++++---
 .../common/inject/MembersInjectorImpl.java           |  4 +++-
 2 files changed, 12 insertions(+), 4 deletions(-)

diff --git a/core/src/main/java/org/elasticsearch/cluster/block/ClusterBlocks.java b/core/src/main/java/org/elasticsearch/cluster/block/ClusterBlocks.java
index bbc454b02df..25e9203890c 100644
--- a/core/src/main/java/org/elasticsearch/cluster/block/ClusterBlocks.java
+++ b/core/src/main/java/org/elasticsearch/cluster/block/ClusterBlocks.java
@@ -64,11 +64,15 @@ public class ClusterBlocks extends AbstractDiffable<ClusterBlocks> {
         levelHolders = new ImmutableLevelHolder[ClusterBlockLevel.values().length];
         for (final ClusterBlockLevel level : ClusterBlockLevel.values()) {
             Predicate<ClusterBlock> containsLevel = block -> block.contains(level);
-            Set<ClusterBlock> newGlobal = unmodifiableSet(global.stream().filter(containsLevel).collect(toSet()));
+            Set<ClusterBlock> newGlobal = unmodifiableSet(global.stream()
+                    .filter(containsLevel)
+                    .collect(toSet()));
 
             ImmutableMap.Builder<String, Set<ClusterBlock>> indicesBuilder = ImmutableMap.builder();
             for (Map.Entry<String, Set<ClusterBlock>> entry : indicesBlocks.entrySet()) {
-                indicesBuilder.put(entry.getKey(), unmodifiableSet(entry.getValue().stream().filter(containsLevel).collect(toSet())));
+                indicesBuilder.put(entry.getKey(), unmodifiableSet(entry.getValue().stream()
+                        .filter(containsLevel)
+                        .collect(toSet())));
             }
 
             levelHolders[level.id()] = new ImmutableLevelHolder(newGlobal, indicesBuilder.build());
@@ -187,7 +191,9 @@ public class ClusterBlocks extends AbstractDiffable<ClusterBlocks> {
             return null;
         }
         Function<String, Stream<ClusterBlock>> blocksForIndexAtLevel = index -> blocksForIndex(level, index).stream();
-        Stream<ClusterBlock> blocks = concat(global(level).stream(), Stream.of(indices).flatMap(blocksForIndexAtLevel));
+        Stream<ClusterBlock> blocks = concat(
+                global(level).stream(),
+                Stream.of(indices).flatMap(blocksForIndexAtLevel));
         return new ClusterBlockException(unmodifiableSet(blocks.collect(toSet())));
     }
 
diff --git a/core/src/main/java/org/elasticsearch/common/inject/MembersInjectorImpl.java b/core/src/main/java/org/elasticsearch/common/inject/MembersInjectorImpl.java
index bdd0bdefc68..f88ecd67db6 100644
--- a/core/src/main/java/org/elasticsearch/common/inject/MembersInjectorImpl.java
+++ b/core/src/main/java/org/elasticsearch/common/inject/MembersInjectorImpl.java
@@ -116,6 +116,8 @@ class MembersInjectorImpl<T> implements MembersInjector<T> {
     }
 
     public Set<InjectionPoint> getInjectionPoints() {
-        return unmodifiableSet(memberInjectors.stream().map(SingleMemberInjector::getInjectionPoint).collect(toSet()));
+        return unmodifiableSet(memberInjectors.stream()
+                .map(SingleMemberInjector::getInjectionPoint)
+                .collect(toSet()));
     }
 }