org.eclipse.jetty.websocket.common.message

Class MessageReader

java.lang.Object

java.io.Reader

org.eclipse.jetty.websocket.common.message.MessageReader

All Implemented Interfaces:

Closeable, AutoCloseable, Readable, MessageAppender

public class MessageReader
extends Reader
implements MessageAppender

Support class for reading text message data as an Reader.

Due to the spec, this reader is forced to use the UTF8 charset.

Field Summary

Fields inherited from class java.io.Reader

lock

Constructor Summary

Constructors

Constructor and Description
MessageReader(AnnotatedEventDriver driver)

Method Summary

Methods

Modifier and Type	Method and Description
void	appendMessage(ByteBuffer payload) Append the payload to the message.
void	close()
void	messageComplete() Notification that message is to be considered complete.
int	read(char[] cbuf, int off, int len)

Methods inherited from class java.io.Reader

mark, markSupported, read, read, read, ready, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageReader

public MessageReader(AnnotatedEventDriver driver)

Method Detail

appendMessage

public void appendMessage(ByteBuffer payload)
                   throws IOException

Description copied from interface: MessageAppender

Append the payload to the message.

Specified by:

appendMessage in interface MessageAppender

Parameters:

payload - the payload to append.

Throws:

IOException - if unable to append the payload

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class Reader

Throws:

IOException

messageComplete

public void messageComplete()

Description copied from interface: MessageAppender

Notification that message is to be considered complete.

Specified by:

messageComplete in interface MessageAppender

read

public int read(char[] cbuf,
       int off,
       int len)
         throws IOException

Specified by:

read in class Reader

Throws:

IOException