com.github.akurilov.commons.io

Class IoUtil

java.lang.Object

com.github.akurilov.commons.io.IoUtil

public abstract class IoUtil
extends java.lang.Object

The class contains 2 utility methods to wrap the stream into the reusable and stateless thread local byte channel.

Field Summary

Fields

Modifier and Type	Field and Description
static int	REUSABLE_BUFF_SIZE_MAX
static int	REUSABLE_BUFF_SIZE_MIN

Method Summary

Modifier and Type	Method and Description
static java.nio.channels.ReadableByteChannel	getThreadLocalInputChannel(java.io.InputStream in, long remainingSize) Wraps the given input stream into the special stateless and reusable (thread local) byte channel
static java.nio.channels.WritableByteChannel	getThreadLocalOutputChannel(java.io.OutputStream out, long remainingSize) Wraps the given output stream into the special stateless and reusable (thread local) byte channel

Methods inherited from class java.lang.Object

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

Field Detail

REUSABLE_BUFF_SIZE_MIN

public static final int REUSABLE_BUFF_SIZE_MIN

See Also:

Constant Field Values

REUSABLE_BUFF_SIZE_MAX

public static final int REUSABLE_BUFF_SIZE_MAX

See Also:

Constant Field Values

Method Detail

getThreadLocalInputChannel

public static java.nio.channels.ReadableByteChannel getThreadLocalInputChannel(java.io.InputStream in,
                                                                               long remainingSize)
                                                                        throws java.lang.IllegalStateException

Wraps the given input stream into the special stateless and reusable (thread local) byte channel

Parameters:

in - the input stream to wrap

remainingSize - the estimated size of the data to be read from the given input

Returns:

readable byte channel

Throws:

java.lang.IllegalStateException - if negative remaining size is specified

getThreadLocalOutputChannel

public static java.nio.channels.WritableByteChannel getThreadLocalOutputChannel(java.io.OutputStream out,
                                                                                long remainingSize)
                                                                         throws java.lang.IllegalStateException

Wraps the given output stream into the special stateless and reusable (thread local) byte channel

Parameters:

out - the output stream to wrap into the byte channel

remainingSize - the estimated size of the data to be written to the given output

Returns:

writable byte channel

Throws:

java.lang.IllegalStateException - if negative remaining size is specified