com.github.akurilov.commons.io.util

Class InputStreamWrapperChannel

java.lang.Object

com.github.akurilov.commons.io.util.BufferedByteChannelBase

com.github.akurilov.commons.io.util.InputStreamWrapperChannel

All Implemented Interfaces:

BufferedByteChannel, BufferedReadableByteChannel, java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, java.nio.channels.ReadableByteChannel

public class InputStreamWrapperChannel
extends BufferedByteChannelBase
implements BufferedReadableByteChannel

Field Summary

Fields inherited from class com.github.akurilov.commons.io.util.BufferedByteChannelBase

bb, buffer, REUSABLE_BUFF_SIZE_MAX, REUSABLE_BUFF_SIZE_MIN

Constructor Summary

Constructors

Constructor and Description
InputStreamWrapperChannel(int buffSize)

Method Summary

Modifier and Type	Method and Description
void	close()
static BufferedReadableByteChannel	getThreadLocalInstance(java.io.InputStream in, long remainingSize) Wraps the given input stream into the special stateless and reusable (thread local) byte channel
int	read(java.nio.ByteBuffer dst)

Methods inherited from class com.github.akurilov.commons.io.util.BufferedByteChannelBase

buffer, isOpen

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.github.akurilov.commons.io.util.BufferedByteChannel

buffer

Methods inherited from interface java.nio.channels.Channel

isOpen

Constructor Detail

InputStreamWrapperChannel

public InputStreamWrapperChannel(int buffSize)

Method Detail

read

public final int read(java.nio.ByteBuffer dst)
               throws java.io.IOException

Specified by:

read in interface java.nio.channels.ReadableByteChannel

Throws:

java.io.IOException

getThreadLocalInstance

public static BufferedReadableByteChannel getThreadLocalInstance(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

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.nio.channels.Channel

Throws:

java.io.IOException