Top Description Fields Constructors Methods
org.eclipse.jetty.websocket.core.messages

public Class MessageWriter

extends Writer
Class Inheritance
Imports
java.io.IOException, .Writer, java.nio.CharBuffer, java.nio.charset.CharsetEncoder, .CodingErrorAction, org.eclipse.jetty.io.ByteBufferPool, org.eclipse.jetty.util.Callback, org.eclipse.jetty.websocket.core.CoreSession, .OpCode

Support for writing a single WebSocket TEXT message via a Writer

Note

Per WebSocket spec, all WebSocket TEXT messages must be encoded in UTF-8

Field Summary

Modifier and TypeField and Description
private final MessageOutputStream
private final CharsetEncoder
Inherited from java.io.Writer:
lock

Constructor Summary

AccessConstructor and Description
public
MessageWriter(CoreSession coreSession, ByteBufferPool bufferPool)

Method Summary

Modifier and TypeMethod and Description
public void
close()

Implements abstract java.io.Writer.close.

Implements java.io.Closeable.close.

Closes the stream, flushing it first.

public void
flush()

Implements abstract java.io.Writer.flush.

Implements java.io.Flushable.flush.

Flushes the stream.

public void
public void
write(char[]
Array of characters
cbuf
,
int
Offset from which to start writing characters
off
,
int
Number of characters to write
len
)

Implements abstract java.io.Writer.write.

Writes a portion of an array of characters.

Inherited from java.io.Writer:
appendappendappendnullWriterwritewritewritewrite

Field Detail

outputStreamback to summary
private final MessageOutputStream outputStream
utf8Encoderback to summary
private final CharsetEncoder utf8Encoder

Constructor Detail

MessageWriterback to summary
public MessageWriter(CoreSession coreSession, ByteBufferPool bufferPool)

Method Detail

closeback to summary
public void close() throws IOException

Implements abstract java.io.Writer.close.

Implements java.io.Closeable.close.

Doc from java.io.Writer.close.

Closes the stream, flushing it first. Once the stream has been closed, further write() or flush() invocations will cause an IOException to be thrown. Closing a previously closed stream has no effect.

Annotations
@Override
Exceptions
IOException:
If an I/O error occurs
flushback to summary
public void flush() throws IOException

Implements abstract java.io.Writer.flush.

Implements java.io.Flushable.flush.

Doc from java.io.Writer.flush.

Flushes the stream. If the stream has saved any characters from the various write() methods in a buffer, write them immediately to their intended destination. Then, if that destination is another character or byte stream, flush it. Thus one flush() invocation will flush all the buffers in a chain of Writers and OutputStreams.

If the intended destination of this stream is an abstraction provided by the underlying operating system, for example a file, then flushing the stream guarantees only that bytes previously written to the stream are passed to the operating system for writing; it does not guarantee that they are actually written to a physical device such as a disk drive.

Annotations
@Override
Exceptions
IOException:
If an I/O error occurs
setCallbackback to summary
public void setCallback(Callback callback)
writeback to summary
public void write(char[] cbuf, int off, int len) throws IOException

Implements abstract java.io.Writer.write.

Doc from java.io.Writer.write.

Writes a portion of an array of characters.

Parameters
cbuf:char[]

Array of characters

off:int

Offset from which to start writing characters

len:int

Number of characters to write

Annotations
@Override
Exceptions
IOException:
If an I/O error occurs