org.infinispan.util.stream
Class Streams

java.lang.Object
  extended by org.infinispan.util.stream.Streams

public class Streams
extends Object

A collection of stream related utility methods.

Exceptions that are thrown and not explicitly declared are ignored.

Since:
4.2
Author:
Jason Dillon

Field Summary
static int DEFAULT_BUFFER_SIZE
          The default buffer size that will be used for buffered operations.
 
Constructor Summary
Streams()
           
 
Method Summary
static boolean close(InputStream stream)
          Attempt to close an InputStream.
static boolean close(InputStream[] streams)
          Attempt to close an array of InputStreams.
static boolean close(Object stream)
          Attempt to close an InputStream or OutputStream.
static boolean close(Object[] streams)
          Attempt to close an array of InputStreama and/or OutputStreams.
static boolean close(OutputStream stream)
          Attempt to close an OutputStream.
static boolean close(OutputStream[] streams)
          Attempt to close an array of OutputStreams.
static long copy(InputStream input, OutputStream output)
          Copy all of the bytes from the input stream to the output stream.
static long copy(InputStream input, OutputStream output, byte[] buffer)
          Copy all of the bytes from the input stream to the output stream.
static long copy(InputStream input, OutputStream output, int size)
          Copy all of the bytes from the input stream to the output stream.
static long copyb(InputStream input, OutputStream output)
          Copy all of the bytes from the input stream to the output stream wrapping streams in buffers as needed.
static long copySome(InputStream input, OutputStream output, byte[] buffer, long length)
          Copy a limited number of bytes from the input stream to the output stream.
static long copySome(InputStream input, OutputStream output, int size, long length)
          Copy a limited number of bytes from the input stream to the output stream.
static long copySome(InputStream input, OutputStream output, long length)
          Copy a limited number of bytes from the input stream to the output stream.
static boolean fclose(OutputStream stream)
          Attempt to flush and close an OutputStream.
static boolean fclose(OutputStream[] streams)
          Attempt to flush and close an array of OutputStreams.
static boolean flush(OutputStream stream)
          Attempt to flush an OutputStream.
static boolean flush(OutputStream[] streams)
          Attempt to flush an array of OutputStreams.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE
The default buffer size that will be used for buffered operations.

See Also:
Constant Field Values
Constructor Detail

Streams

public Streams()
Method Detail

close

public static boolean close(InputStream stream)
Attempt to close an InputStream.

Parameters:
stream - InputStream to attempt to close.
Returns:
True if stream was closed (or stream was null), or false if an exception was thrown.

close

public static boolean close(OutputStream stream)
Attempt to close an OutputStream.

Parameters:
stream - OutputStream to attempt to close.
Returns:
True if stream was closed (or stream was null), or false if an exception was thrown.

close

public static boolean close(Object stream)
Attempt to close an InputStream or OutputStream.

Parameters:
stream - Stream to attempt to close.
Returns:
True if stream was closed (or stream was null), or false if an exception was thrown.
Throws:
IllegalArgumentException - Stream is not an InputStream or OuputStream.

close

public static boolean close(InputStream[] streams)
Attempt to close an array of InputStreams.

Parameters:
streams - Array of InputStreams to attempt to close.
Returns:
True if all streams were closed, or false if an exception was thrown.

close

public static boolean close(OutputStream[] streams)
Attempt to close an array of OutputStreams.

Parameters:
streams - Array of OutputStreams to attempt to close.
Returns:
True if all streams were closed, or false if an exception was thrown.

close

public static boolean close(Object[] streams)
Attempt to close an array of InputStreama and/or OutputStreams.

Parameters:
streams - Array of streams to attempt to close.
Returns:
True if all streams were closed, or false if an exception was thrown.
Throws:
IllegalArgumentException - Stream is not an InputStream or OuputStream. Closing stops at the last valid stream object in this case.

fclose

public static boolean fclose(OutputStream stream)
Attempt to flush and close an OutputStream.

Parameters:
stream - OutputStream to attempt to flush and close.
Returns:
True if stream was flushed and closed, or false if an exception was thrown.

fclose

public static boolean fclose(OutputStream[] streams)
Attempt to flush and close an array of OutputStreams.

Parameters:
streams - OutputStreams to attempt to flush and close.
Returns:
True if all streams were flushed and closed, or false if an exception was thrown.

flush

public static boolean flush(OutputStream stream)
Attempt to flush an OutputStream.

Parameters:
stream - OutputStream to attempt to flush.
Returns:
True if stream was flushed (or stream was null), or false if an exception was thrown.

flush

public static boolean flush(OutputStream[] streams)
Attempt to flush an array of OutputStreams.

Parameters:
streams - OutputStreams to attempt to flush.
Returns:
True if all streams were flushed, or false if an exception was thrown.

copy

public static long copy(InputStream input,
                        OutputStream output,
                        byte[] buffer)
                 throws IOException
Copy all of the bytes from the input stream to the output stream.

Parameters:
input - Stream to read bytes from.
output - Stream to write bytes to.
buffer - The buffer to use while copying.
Returns:
The total number of bytes copied.
Throws:
IOException - Failed to copy bytes.

copy

public static long copy(InputStream input,
                        OutputStream output,
                        int size)
                 throws IOException
Copy all of the bytes from the input stream to the output stream.

Parameters:
input - Stream to read bytes from.
output - Stream to write bytes to.
size - The size of the buffer to use while copying.
Returns:
The total number of bytes copied.
Throws:
IOException - Failed to copy bytes.

copy

public static long copy(InputStream input,
                        OutputStream output)
                 throws IOException
Copy all of the bytes from the input stream to the output stream.

Parameters:
input - Stream to read bytes from.
output - Stream to write bytes to.
Returns:
The total number of bytes copied.
Throws:
IOException - Failed to copy bytes.

copyb

public static long copyb(InputStream input,
                         OutputStream output)
                  throws IOException
Copy all of the bytes from the input stream to the output stream wrapping streams in buffers as needed.

Parameters:
input - Stream to read bytes from.
output - Stream to write bytes to.
Returns:
The total number of bytes copied.
Throws:
IOException - Failed to copy bytes.

copySome

public static long copySome(InputStream input,
                            OutputStream output,
                            byte[] buffer,
                            long length)
                     throws IOException
Copy a limited number of bytes from the input stream to the output stream.

Parameters:
input - Stream to read bytes from.
output - Stream to write bytes to.
buffer - The buffer to use while copying.
length - The maximum number of bytes to copy.
Returns:
The total number of bytes copied.
Throws:
IOException - Failed to copy bytes.

copySome

public static long copySome(InputStream input,
                            OutputStream output,
                            int size,
                            long length)
                     throws IOException
Copy a limited number of bytes from the input stream to the output stream.

Parameters:
input - Stream to read bytes from.
output - Stream to write bytes to.
size - The size of the buffer to use while copying.
length - The maximum number of bytes to copy.
Returns:
The total number of bytes copied.
Throws:
IOException - Failed to copy bytes.

copySome

public static long copySome(InputStream input,
                            OutputStream output,
                            long length)
                     throws IOException
Copy a limited number of bytes from the input stream to the output stream.

Parameters:
input - Stream to read bytes from.
output - Stream to write bytes to.
length - The maximum number of bytes to copy.
Returns:
The total number of bytes copied.
Throws:
IOException - Failed to copy bytes.

-->

Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.