Tyrus 2.2.0 · org.glassfish.tyrus.core.ReaderBuffer · APIdia, the JavaDoc alternative

Buffer used for the case when partial messages are received by the MessageHandler.Whole.

For the first received message MessageHandler.Whole#onMessage(Object) is called within a new executor to allow blocking reading of passed Reader.

Field Summary

Modifier and Type	Field and Description
private volatile StringBuffer	buffer
private final AtomicBoolean	buffering
private volatile int	bufferSize
private final Condition	condition
private volatile int	currentlyBuffered
private final ExecutorService	executorService
private final ReentrantLock	lock
private static final Logger	LOGGER
private volatile MessageHandler.Whole<Reader>	messageHandler
private volatile BufferedStringReader	reader
private volatile boolean	receivedLast
private volatile boolean	sessionClosed

Constructor Summary

Access	Constructor and Description
public	ReaderBuffer(ExecutorService executorService) Constructor.

Method Summary

Modifier and Type	Method and Description
public void	appendMessagePart(String the message. message, boolean should be `true` iff this is the last part of the message, `false` otherwise. last) Append next message part to the buffer.
private void	checkClosedSession()
public void	finishReading() Finish reading of the buffer.
public char[]	Returns: next received chars. getNextChars(int number) Get next received chars.
pack-priv void	onSessionClosed()
public void	resetBuffer(int the size to be set. bufferSize) Reset the buffer size.
public void	setMessageHandler(MessageHandler.Whole<Reader> `MessageHandler` that will consume the constructed `java.io.InputStream`. messageHandler) Set the `MessageHandler` that will consume the constructed `java.io.InputStream`.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

buffer	back to summary
private volatile StringBuffer buffer

buffering	back to summary
private final AtomicBoolean buffering

bufferSize	back to summary
private volatile int bufferSize

condition	back to summary
private final Condition condition

currentlyBuffered	back to summary
private volatile int currentlyBuffered

executorService	back to summary
private final ExecutorService executorService

lock	back to summary
private final ReentrantLock lock

LOGGER	back to summary
private static final Logger LOGGER

messageHandler	back to summary
private volatile MessageHandler.Whole<Reader> messageHandler

reader	back to summary
private volatile BufferedStringReader reader

receivedLast	back to summary
private volatile boolean receivedLast

sessionClosed	back to summary
private volatile boolean sessionClosed

Constructor Detail

ReaderBuffer	back to summary
public ReaderBuffer(ExecutorService executorService) Constructor.

Method Detail

appendMessagePart back to summary

appendMessagePart	back to summary
public void appendMessagePart(String message, boolean last) Append next message part to the buffer. Parameters message:String the message. last:boolean should be `true` iff this is the last part of the message, `false` otherwise.

public void appendMessagePart(String message, boolean last)

Append next message part to the buffer.

Parameters

message:String: the message.
last:boolean: should be true iff this is the last part of the message, false otherwise.

checkClosedSession	back to summary
private void checkClosedSession() throws IOException

finishReading	back to summary
public void finishReading() Finish reading of the buffer.

getNextChars	back to summary
public char[] getNextChars(int number) throws IOException Get next received chars. Returns:char[] next received chars.

getNextChars

back to summary

public char[] getNextChars(int number) throws IOException

Get next received chars.

Returns:char[]: next received chars.

onSessionClosed	back to summary
pack-priv void onSessionClosed()

resetBuffer	back to summary
public void resetBuffer(int bufferSize) Reset the buffer size. Parameters bufferSize:int the size to be set.

resetBuffer

back to summary

public void resetBuffer(int bufferSize)

Reset the buffer size.

Parameters

bufferSize:int: the size to be set.

setMessageHandler back to summary

setMessageHandler	back to summary
public void setMessageHandler(MessageHandler.Whole<Reader> messageHandler) Set the `MessageHandler` that will consume the constructed `java.io.InputStream`. Parameters messageHandler:MessageHandler.Whole<Reader> `MessageHandler` that will consume the constructed `java.io.InputStream`.

public void setMessageHandler(MessageHandler.Whole<Reader> messageHandler)

Set the MessageHandler that will consume the constructed java.io.InputStream.

Parameters

messageHandler:MessageHandler.Whole<Reader>: MessageHandler that will consume the constructed java.io.InputStream.

pack-priv Class ReaderBuffer

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail