Explicit lambda argument types

Author: safris

src/main/java/org/libj/io/FileUtil.java

@@ -48,7 +48,6 @@ public final class FileUtil {
   private static ConcurrentMap<Path,ArrayList<Filter<? super Path>>> deleteOnExit;
   private static final AtomicBoolean deleteOnExitMutex = new AtomicBoolean();
 
-  // FIXME: This synchronization seems so rigid
   private static void deleteOnExit(final Path path, final Filter<? super Path> filter, final Consumer<Throwable> onThrow) {
     if (!deleteOnExitMutex.get()) {
       synchronized (deleteOnExitMutex) {
@@ -116,7 +115,7 @@ public static File getTempDir() {
     return TEMP_DIR == null ? TEMP_DIR = new File(System.getProperty("java.io.tmpdir")) : TEMP_DIR;
   }
 
-  private static final Filter<Path> anyStreamFilter = p -> true;
+  private static final Filter<Path> anyStreamFilter = (final Path p) -> true;
 
   private static void deleteAll0(final Path path, final Filter<? super Path> filter) throws IOException {
     if (Files.isDirectory(path)) {
@@ -290,7 +289,7 @@ public static Path copyAll(final Path source, final Path target, final CopyOptio
         if (options[i] == StandardCopyOption.REPLACE_EXISTING && !deleteAll(target))
           throw new DirectoryNotEmptyException(target.toString());
 
-    Files.walk(source).forEach(rethrow(path -> {
+    Files.walk(source).forEach(rethrow((final Path path) -> {
       final Path resolved = target.resolve(source.relativize(path));
       if (Files.isRegularFile(path))
         Files.copy(path, resolved, options);

src/main/java/org/libj/io/Streams.java

@@ -578,13 +578,14 @@ public static InputStream mergeAsync(final InputStream ... streams) throws IOExc
   }
 
   private static InputStream merge(final boolean sync, final InputStream ... streams) throws IOException {
-    if (streams.length == 0)
+    final int len = streams.length;
+    if (len == 0)
       throw new IllegalArgumentException("streams.length == 0");
 
-    if (streams.length == 1)
+    if (len == 1)
       return streams[0];
 
-    final CountDownLatch latch = new CountDownLatch(streams.length + 1);
+    final CountDownLatch latch = new CountDownLatch(len + 1);
     try (final PipedOutputStream pipedOut = new PipedOutputStream() {
       @Override
       public void close() throws IOException {
@@ -595,8 +596,8 @@ public void close() throws IOException {
       }
     }) {
       final InputStream pipedIn = new PipedInputStream(pipedOut, DEFAULT_SOCKET_BUFFER_SIZE);
-      for (int i = 0, i$ = streams.length; i < i$; ++i) { // [A]
-        pipe(streams[i], pipedOut, false, sync, p -> {
+      for (int i = 0; i < len; ++i) { // [A]
+        pipe(streams[i], pipedOut, false, sync, (final IOException p) -> {
           try {
             pipedOut.close();
           }

src/main/java/org/libj/io/TeeOutputStream.java

@@ -24,30 +24,38 @@
  * {@link OutputStream} that delegates its method calls to an array of output streams.
  */
 public class TeeOutputStream extends OutputStream {
+  private final OutputStream stream;
   private final OutputStream[] streams;
+  private final int len;
 
   /**
    * Construct a new {@link TeeOutputStream} with the specified {@link OutputStream} instances.
    * <p>
    * Streams will be written to in the order of the provided array.
    *
-   * @param streams The streams to which this stream's method calls will be delegated.
-   * @throws NullPointerException If {@code streams} is null or empty, or if any stream in the {@code streams} array is null.
+   * @param stream The first stream to which this stream's method calls will be delegated.
+   * @param streams The other streams to which this stream's method calls will be delegated.
+   * @throws NullPointerException If {@code stream} or {@code streams} is null, or if any stream in the {@code streams} array is null.
    */
-  public TeeOutputStream(final OutputStream ... streams) {
-    if (Objects.requireNonNull(streams).length == 0)
-      throw new IllegalArgumentException("Empty array");
-
-    for (int i = 0, i$ = streams.length; i < i$; ++i) // [A]
-      Objects.requireNonNull(streams[i], "member at index " + i + " is null");
-
+  public TeeOutputStream(final OutputStream stream, final OutputStream ... streams) {
+    this.stream = Objects.requireNonNull(stream, "member at index 0 is null");;
     this.streams = streams;
+    this.len = streams.length;
+    for (int i = 0; i < len; ++i) // [A]
+      Objects.requireNonNull(streams[i], "member at index " + (i + 1) + " is null");
   }
 
   @Override
   public void write(final int b) throws IOException {
     IOException exception = null;
-    for (int i = 0, i$ = streams.length; i < i$; ++i) { // [A]
+    try {
+      stream.write(b);
+    }
+    catch (final IOException e) {
+      exception = e;
+    }
+
+    for (int i = 0; i < len; ++i) { // [A]
       try {
         streams[i].write(b);
       }
@@ -66,7 +74,14 @@ public void write(final int b) throws IOException {
   @Override
   public void write(final byte[] b) throws IOException {
     IOException exception = null;
-    for (int i = 0, i$ = streams.length; i < i$; ++i) { // [A]
+    try {
+      stream.write(b);
+    }
+    catch (final IOException e) {
+      exception = e;
+    }
+
+    for (int i = 0; i < len; ++i) { // [A]
       try {
         streams[i].write(b);
       }
@@ -85,7 +100,14 @@ public void write(final byte[] b) throws IOException {
   @Override
   public void write(final byte[] b, final int off, final int len) throws IOException {
     IOException exception = null;
-    for (int i = 0, i$ = streams.length; i < i$; ++i) { // [A]
+    try {
+      stream.write(b, off, len);
+    }
+    catch (final IOException e) {
+      exception = e;
+    }
+
+    for (int i = 0; i < len; ++i) { // [A]
       try {
         streams[i].write(b, off, len);
       }
@@ -104,7 +126,14 @@ public void write(final byte[] b, final int off, final int len) throws IOExcepti
   @Override
   public void flush() throws IOException {
     IOException exception = null;
-    for (int i = 0, i$ = streams.length; i < i$; ++i) { // [A]
+    try {
+      stream.flush();
+    }
+    catch (final IOException e) {
+      exception = e;
+    }
+
+    for (int i = 0; i < len; ++i) { // [A]
       try {
         streams[i].flush();
       }
@@ -123,7 +152,14 @@ public void flush() throws IOException {
   @Override
   public void close() throws IOException {
     IOException exception = null;
-    for (int i = 0, i$ = streams.length; i < i$; ++i) { // [A]
+    try {
+      stream.close();
+    }
+    catch (final IOException e) {
+      exception = e;
+    }
+
+    for (int i = 0; i < len; ++i) { // [A]
       try {
         streams[i].close();
       }