org.glassfish.jersey.media.sse

Class EventInput

java.lang.Object

javax.ws.rs.core.GenericType<T>

org.glassfish.jersey.client.ChunkedInput<InboundEvent>

org.glassfish.jersey.media.sse.EventInput

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

SseEventPublisher

public class EventInput
extends ChunkedInput<InboundEvent>

Inbound Server-Sent Events channel. The input channel lets you serially read & consume SSE events as they arrive.

Author:

Marek Potociar

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	EventInput(InputStream inputStream, Annotation[] annotations, javax.ws.rs.core.MediaType mediaType, javax.ws.rs.core.MultivaluedMap<String,String> headers, MessageBodyWorkers messageBodyWorkers, PropertiesDelegate propertiesDelegate) Package-private constructor used by the ChunkedInputReader.

Method Summary

Methods inherited from class org.glassfish.jersey.client.ChunkedInput

close, createMultiParser, createParser, createParser, getChunkType, getParser, isClosed, read, setChunkType, setChunkType, setParser

Methods inherited from class javax.ws.rs.core.GenericType

equals, forInstance, getRawType, getType, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

EventInput

protected EventInput(InputStream inputStream,
                     Annotation[] annotations,
                     javax.ws.rs.core.MediaType mediaType,
                     javax.ws.rs.core.MultivaluedMap<String,String> headers,
                     MessageBodyWorkers messageBodyWorkers,
                     PropertiesDelegate propertiesDelegate)

Package-private constructor used by the ChunkedInputReader.

Parameters:

inputStream - response input stream.

annotations - annotations associated with response entity.

mediaType - response entity media type.

headers - response headers.

messageBodyWorkers - message body workers.

propertiesDelegate - properties delegate for this request/response.