Class EncodedInputStream

java.lang.Object

java.io.InputStream

org.apache.derby.client.net.EncodedInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public final class EncodedInputStream
extends InputStream

Create an encoded stream from a Reader. This is an internal class, used to pass readers of characters as streams of bytes. The characters will be represented according to the specified encoding. It is up to the caller to ensure the specified encoding is available, and in general only encodings available as default from Java 1.3 and up should be used. Currently, the encodings 'UTF8' and 'UTF-16BE' are used. Streams are obtained by calling the static methods of this class, for instance createUTF8Stream.

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	BUFFERED_CHAR_LEN
private final char[]	decodedBuffer_
private ByteArrayInputStream	encodedInputStream_
private PublicBufferOutputStream	encodedOutputStream_
private OutputStreamWriter	encodedStreamWriter_
private Reader	reader_
private static final ByteArrayInputStream	suspendMarker
private static final Charset	UTF_16BE
private static final Charset	UTF_8

Constructor Summary

Constructors

Modifier	Constructor	Description
private	EncodedInputStream(Reader reader, Charset encoding, int charBufferSize, int initialByteBufferSize)	Create an encoded stream for the specified Reader.

Method Summary

Modifier and Type	Method	Description
int	available()
void	close()
(package private) static EncodedInputStream	createUTF16BEStream(Reader reader)	Create a UTF-16BE encoded stream from the given Reader.
static EncodedInputStream	createUTF8Stream(Reader reader)	Create a UTF-8 encoded stream from the given Reader.
int	read()
private ByteArrayInputStream	reEncode(Reader reader)

Methods inherited from class InputStream

mark, markSupported, nullInputStream, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class Object

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

Field Details

UTF_8

private static final Charset UTF_8

UTF_16BE

private static final Charset UTF_16BE

BUFFERED_CHAR_LEN

private static final int BUFFERED_CHAR_LEN

See Also:

• Constant Field Values

suspendMarker

private static final ByteArrayInputStream suspendMarker

reader_

private Reader reader_

decodedBuffer_

private final char[] decodedBuffer_

encodedStreamWriter_

private OutputStreamWriter encodedStreamWriter_

encodedOutputStream_

private PublicBufferOutputStream encodedOutputStream_

encodedInputStream_

private ByteArrayInputStream encodedInputStream_

Constructor Details

EncodedInputStream

private EncodedInputStream(Reader reader,
 Charset encoding,
 int charBufferSize,
 int initialByteBufferSize)

Create an encoded stream for the specified Reader.

Parameters:

reader - the Reader to read characters from

encoding - the encoding to use in the encoded stream

charBufferSize - the size of the char buffer. This is the number of characters read at once from the Reader.

initialByteBufferSize - the initial size of the byte buffer. holding the encoded bytes

Method Details

createUTF8Stream

public static EncodedInputStream createUTF8Stream(Reader reader)

Create a UTF-8 encoded stream from the given Reader.

Parameters:

reader - the Reader to read characters from.

Returns:

a byte-stream with UTF-8 encoded characters

createUTF16BEStream

static EncodedInputStream createUTF16BEStream(Reader reader)

Create a UTF-16BE encoded stream from the given Reader.

Parameters:

reader - the Reader to read characters from.

Returns:

a byte-stream with UTF-16BE encoded characters

reEncode

private ByteArrayInputStream reEncode(Reader reader)
                               throws IOException

Throws:

IOException

available

public int available()
              throws IOException

Overrides:

available in class InputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

Throws:

IOException

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException