Package | Description |
---|---|
org.glassfish.jersey.server |
Jersey server-side classes.
|
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ConcurrentLinkedQueue<ChunkedOutput<T>> |
Broadcaster.chunkedOutputs |
Modifier and Type | Method and Description |
---|---|
<OUT extends ChunkedOutput<T>> |
Broadcaster.add(OUT chunkedOutput)
Register
ChunkedOutput to this Broadcaster instance. |
<OUT extends ChunkedOutput<T>> |
Broadcaster.remove(OUT chunkedOutput)
Un-register
ChunkedOutput from this Broadcaster instance. |
Modifier and Type | Method and Description |
---|---|
private void |
Broadcaster.fireOnClose(ChunkedOutput<T> chunkedOutput) |
private void |
Broadcaster.fireOnException(ChunkedOutput<T> chunkedOutput,
java.lang.Exception exception) |
long |
ChunkedResponseWriter.getSize(ChunkedOutput<?> chunkedOutput,
java.lang.Class<?> type,
java.lang.reflect.Type genericType,
java.lang.annotation.Annotation[] annotations,
javax.ws.rs.core.MediaType mediaType) |
void |
BroadcasterListener.onClose(ChunkedOutput<T> chunkedOutput)
Called when the chunkedOutput has been closed (either by client closing the connection or by calling
close() on the server side. |
void |
Broadcaster.onClose(ChunkedOutput<T> chunkedOutput)
Called when the chunkedOutput has been closed (either by client closing the connection or by calling
close() on the server side. |
void |
BroadcasterListener.onException(ChunkedOutput<T> chunkedOutput,
java.lang.Exception exception)
Called when exception was thrown by a given chunked response when trying to write to it or close it.
|
void |
Broadcaster.onException(ChunkedOutput<T> chunkedOutput,
java.lang.Exception exception)
Called when exception was thrown by a given chunked response when trying to write to it or close it.
|
void |
ChunkedResponseWriter.writeTo(ChunkedOutput<?> chunkedOutput,
java.lang.Class<?> type,
java.lang.reflect.Type genericType,
java.lang.annotation.Annotation[] annotations,
javax.ws.rs.core.MediaType mediaType,
javax.ws.rs.core.MultivaluedMap<java.lang.String,java.lang.Object> httpHeaders,
java.io.OutputStream entityStream) |
Modifier and Type | Method and Description |
---|---|
private void |
Broadcaster.forEachOutput(Broadcaster.Task<ChunkedOutput<T>> t) |