/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package examples.util;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import org.apache.commons.net.io.Util;

/***
 * This is a utility class providing a reader/writer capability required
 * by the weatherTelnet, rexec, rshell, and rlogin example programs.
 * The only point of the class is to hold the static method readWrite
 * which spawns a reader thread and a writer thread.  The reader thread
 * reads from a local input source (presumably stdin) and writes the
 * data to a remote output destination.  The writer thread reads from
 * a remote input source and writes to a local output destination.
 * The threads terminate when the remote input source closes.
 * <p>
 ***/

public final class IOUtil
{

    public static final void readWrite(final InputStream remoteInput,
                                       final OutputStream remoteOutput,
                                       final InputStream localInput,
                                       final OutputStream localOutput)
    {
        Thread reader, writer;

        reader = new Thread()
                 {
                     @Override
                     public void run()
                     {
                         int ch;

                         try
                         {
                             while (!interrupted() && (ch = localInput.read()) != -1)
                             {
                                 remoteOutput.write(ch);
                                 remoteOutput.flush();
                             }
                         }
                         catch (IOException e)
                         {
                             //e.printStackTrace();
                         }
                     }
                 }
                 ;


        writer = new Thread()
                 {
                     @Override
                     public void run()
                     {
                         try
                         {
                             Util.copyStream(remoteInput, localOutput);
                         }
                         catch (IOException e)
                         {
                             e.printStackTrace();
                             System.exit(1);
                         }
                     }
                 };


        writer.setPriority(Thread.currentThread().getPriority() + 1);

        writer.start();
        reader.setDaemon(true);
        reader.start();

        try
        {
            writer.join();
            reader.interrupt();
        }
        catch (InterruptedException e)
        {
        }
    }

}


@@ -821,16 +821,42 @@
 .util;%0A%0A
+import java.io.Closeable;%0A
 import j
@@ -928,24 +928,49 @@
 tputStream;%0A
+import java.net.Socket;%0A%0A
 import org.a
@@ -1000,17 +1000,16 @@
 il;%0A%0A/**
-*
 %0A * This
@@ -1150,83 +1150,122 @@
 %0A * 
-The only point of the class is to hold the static method readWrite%0A * which
+%3Cp%3E%0A * It also contains some other common IO methods.%0A */%0A%0Apublic final class IOUtil%0A%7B%0A%0A    /**%0A     * This method
  spa
@@ -1304,17 +1304,16 @@
  thread.
- 
  The rea
@@ -1323,16 +1323,20 @@
  thread%0A
+    
  * reads
@@ -1396,16 +1396,20 @@
 tes the%0A
+    
  * data 
@@ -1470,16 +1470,20 @@
 ds from%0A
+    
  * a rem
@@ -1541,16 +1541,20 @@
 nation.%0A
+    
  * The t
@@ -1612,49 +1612,126 @@
 s.%0A 
-* %3Cp%3E%0A ***/%0A%0Apublic final class IOUtil%0A%7B%0A
+    * %0A     * @param remoteInput%0A     * @param remoteOutput%0A     * @param localInput%0A     * @param localOutput%0A     */
 %0A   
@@ -3629,11 +3629,845 @@
 %0A    %7D%0A%0A
+    /**%0A     * Closes the object quietly, catching rather than throwing IOException.%0A     * Intended for use from finally blocks.%0A     * %0A     * @param closeable the object to close, may be %7B@code null%7D%0A     */%0A    public static void closeQuietly(Closeable closeable) %7B%0A        if (closeable != null) %7B%0A            try %7B%0A                closeable.close();%0A            %7D catch (IOException e) %7B%0A            %7D%0A        %7D%0A    %7D%0A%0A    /**%0A     * Closes the socket quietly, catching rather than throwing IOException.%0A     * Intended for use from finally blocks.%0A     * %0A     * @param socket the socket to close, may be %7B@code null%7D%0A     */%0A    public static void closeQuietly(Socket socket) %7B%0A        if (socket != null) %7B%0A            try %7B%0A                socket.close();%0A            %7D catch (IOException e) %7B%0A            %7D%0A        %7D%0A    %7D%0A
 %7D%0A%0A

Add closeQuietly methods to simplify finally blocks