ome.smuggler.core.io

Class StreamOps

java.lang.Object

ome.smuggler.core.io.StreamOps

public class StreamOps
extends java.lang.Object

Utility methods for I/O steam operations.

Constructor Summary

Constructors

Constructor and Description
StreamOps()

Method Summary

Modifier and Type	Method and Description
static void	close(java.io.Closeable stream) Closes the given stream, silently swallowing any IOException.
static byte[]	readAll(java.io.InputStream input) Reads the whole input stream into a byte array.
static <T> T	readLines(java.io.InputStream input, util.lambda.FunctionE<java.util.stream.Stream<java.lang.String>,T> reader, java.nio.charset.Charset... encoding) Builds a stream of lines out of the input data and passes the stream on to the given reader to convert them into a value of type T.
static java.lang.String	readLinesIntoString(java.io.InputStream input) Reads the whole input stream into a string using the default character encoding.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamOps

public StreamOps()

Method Detail

readLines

public static <T> T readLines(java.io.InputStream input,
                              util.lambda.FunctionE<java.util.stream.Stream<java.lang.String>,T> reader,
                              java.nio.charset.Charset... encoding)

Builds a stream of lines out of the input data and passes the stream on to the given reader to convert them into a value of type T.

Type Parameters:

T - the value type.

Parameters:

input - the input data.

reader - converts the stream of lines into a T-value.

encoding - character encoding to use to read the input data; if not given, then the default character encoding is used.

Returns:

the value returned by the reader.

Throws:

java.lang.NullPointerException - if any argument is null.

The following checked exceptions are rethrown as unchecked (i.e. the exception is masked as a runtime exception and thrown as is without wrapping it in a RuntimeException):
IOException if an I/O occurs.

readLinesIntoString

public static java.lang.String readLinesIntoString(java.io.InputStream input)

Reads the whole input stream into a string using the default character encoding.

Parameters:

input - the data to read.

Returns:

the input as string.

Throws:

java.lang.NullPointerException - if the argument is null.

The following checked exceptions are rethrown as unchecked (i.e. the exception is masked as a runtime exception and thrown as is without wrapping it in a RuntimeException):
IOException if an I/O occurs.

readAll

public static byte[] readAll(java.io.InputStream input)

Reads the whole input stream into a byte array.

Parameters:

input - the data to read.

Returns:

all the bytes from the input stream.

Throws:

java.lang.NullPointerException - if the argument is null.

The following checked exceptions are rethrown as unchecked (i.e. the exception is masked as a runtime exception and thrown as is without wrapping it in a RuntimeException):
IOException if an I/O occurs.

close

public static void close(java.io.Closeable stream)

Closes the given stream, silently swallowing any IOException.

Parameters:

stream - the stream to close.

Throws:

java.lang.NullPointerException - if the argument is null.