Commit 8f7ab95e authored by Johnny Lim's avatar Johnny Lim Committed by Stephane Nicoll

Use BufferedReader.lines()

Closes gh-11436
parent 50a4982a
...@@ -28,6 +28,7 @@ import java.io.StringWriter; ...@@ -28,6 +28,7 @@ import java.io.StringWriter;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.stream.Collectors;
import java.util.zip.ZipEntry; import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream; import java.util.zip.ZipInputStream;
...@@ -159,19 +160,9 @@ public final class CommandLineInvoker { ...@@ -159,19 +160,9 @@ public final class CommandLineInvoker {
private List<String> getLines(StringBuffer buffer) { private List<String> getLines(StringBuffer buffer) {
BufferedReader reader = new BufferedReader( BufferedReader reader = new BufferedReader(
new StringReader(buffer.toString())); new StringReader(buffer.toString()));
String line; return reader.lines()
List<String> lines = new ArrayList<>(); .filter((line) -> !line.startsWith("Picked up "))
try { .collect(Collectors.toList());
while ((line = reader.readLine()) != null) {
if (!line.startsWith("Picked up ")) {
lines.add(line);
}
}
}
catch (IOException ex) {
throw new RuntimeException("Failed to read output");
}
return lines;
} }
public int await() throws InterruptedException { public int await() throws InterruptedException {
......
...@@ -18,7 +18,6 @@ package org.springframework.boot.cli.compiler.maven; ...@@ -18,7 +18,6 @@ package org.springframework.boot.cli.compiler.maven;
import java.io.BufferedReader; import java.io.BufferedReader;
import java.io.File; import java.io.File;
import java.io.IOException;
import java.io.PrintWriter; import java.io.PrintWriter;
import java.io.StringReader; import java.io.StringReader;
import java.io.StringWriter; import java.io.StringWriter;
...@@ -174,16 +173,8 @@ public class MavenSettings { ...@@ -174,16 +173,8 @@ public class MavenSettings {
private String indentLines(String input, String indent) { private String indentLines(String input, String indent) {
StringWriter indented = new StringWriter(); StringWriter indented = new StringWriter();
PrintWriter writer = new PrintWriter(indented); PrintWriter writer = new PrintWriter(indented);
String line;
BufferedReader reader = new BufferedReader(new StringReader(input)); BufferedReader reader = new BufferedReader(new StringReader(input));
try { reader.lines().forEach((line) -> writer.println(indent + line));
while ((line = reader.readLine()) != null) {
writer.println(indent + line);
}
}
catch (IOException ex) {
return input;
}
return indented.toString(); return indented.toString();
} }
......
...@@ -29,6 +29,7 @@ import java.util.List; ...@@ -29,6 +29,7 @@ import java.util.List;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.Future; import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import org.junit.Assume; import org.junit.Assume;
import org.junit.rules.TestRule; import org.junit.rules.TestRule;
...@@ -192,12 +193,7 @@ public class CliTester implements TestRule { ...@@ -192,12 +193,7 @@ public class CliTester implements TestRule {
InputStream stream = URI.create("http://localhost:" + port + uri).toURL() InputStream stream = URI.create("http://localhost:" + port + uri).toURL()
.openStream(); .openStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(stream)); BufferedReader reader = new BufferedReader(new InputStreamReader(stream));
String line; return reader.lines().collect(Collectors.joining());
StringBuilder result = new StringBuilder();
while ((line = reader.readLine()) != null) {
result.append(line);
}
return result.toString();
} }
catch (Exception ex) { catch (Exception ex) {
throw new IllegalStateException(ex); throw new IllegalStateException(ex);
......
...@@ -17,7 +17,6 @@ ...@@ -17,7 +17,6 @@
package org.springframework.boot.test.context.assertj; package org.springframework.boot.test.context.assertj;
import java.io.BufferedReader; import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter; import java.io.PrintWriter;
import java.io.StringReader; import java.io.StringReader;
import java.io.StringWriter; import java.io.StringWriter;
...@@ -410,17 +409,11 @@ public class ApplicationContextAssert<C extends ApplicationContext> ...@@ -410,17 +409,11 @@ public class ApplicationContextAssert<C extends ApplicationContext>
BufferedReader reader = new BufferedReader(new StringReader(input)); BufferedReader reader = new BufferedReader(new StringReader(input));
StringWriter writer = new StringWriter(); StringWriter writer = new StringWriter();
PrintWriter printer = new PrintWriter(writer); PrintWriter printer = new PrintWriter(writer);
try { reader.lines().forEach((line) -> {
String line; printer.print(" ");
while ((line = reader.readLine()) != null) { printer.println(line);
printer.print(" "); });
printer.println(line); return writer.toString();
}
return writer.toString();
}
catch (IOException ex) {
return input;
}
} }
} }
......
...@@ -147,17 +147,13 @@ public class RunProcess { ...@@ -147,17 +147,13 @@ public class RunProcess {
} }
private void redirectOutput(Process process) { private void redirectOutput(Process process) {
final BufferedReader reader = new BufferedReader(
new InputStreamReader(process.getInputStream()));
new Thread(() -> { new Thread(() -> {
try { try (BufferedReader reader = new BufferedReader(
String line = reader.readLine(); new InputStreamReader(process.getInputStream()))) {
while (line != null) { reader.lines().forEach((line) -> {
System.out.println(line); System.out.println(line);
line = reader.readLine();
System.out.flush(); System.out.flush();
} });
reader.close();
} }
catch (Exception ex) { catch (Exception ex) {
// Ignore // Ignore
......
...@@ -19,8 +19,8 @@ package org.springframework.boot.diagnostics.analyzer; ...@@ -19,8 +19,8 @@ package org.springframework.boot.diagnostics.analyzer;
import java.io.BufferedReader; import java.io.BufferedReader;
import java.io.IOException; import java.io.IOException;
import java.io.StringReader; import java.io.StringReader;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.stream.Collectors;
import org.junit.Test; import org.junit.Test;
...@@ -125,14 +125,9 @@ public class BeanCurrentlyInCreationFailureAnalyzerTests { ...@@ -125,14 +125,9 @@ public class BeanCurrentlyInCreationFailureAnalyzerTests {
private List<String> readDescriptionLines(FailureAnalysis analysis) private List<String> readDescriptionLines(FailureAnalysis analysis)
throws IOException { throws IOException {
try (BufferedReader lineReader = new BufferedReader( try (BufferedReader reader = new BufferedReader(
new StringReader(analysis.getDescription()))) { new StringReader(analysis.getDescription()))) {
List<String> lines = new ArrayList<>(); return reader.lines().collect(Collectors.toList());
String line;
while ((line = lineReader.readLine()) != null) {
lines.add(line);
}
return lines;
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment