Class HttpClient.ServerSentEventsReader

java.lang.Object

one.nio.http.HttpClient.ResponseReader

one.nio.http.HttpClient.ChunkedLineReader

one.nio.http.HttpClient.ServerSentEventsReader

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<String>, EventSource<String>

Enclosing class:

HttpClient

class HttpClient.ServerSentEventsReader
extends HttpClient.ChunkedLineReader
implements EventSource<String>

Nested Class Summary

Nested classes/interfaces inherited from interface EventSource

EventSource.Event<D>

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	keepAlive

Fields inherited from class HttpClient.ResponseReader

buf, length, pos, socket

Constructor Summary

Constructors

Constructor	Description
ServerSentEventsReader(Socket socket, int bufferSize)

Method Summary

Modifier and Type	Method	Description
void	close()
EventSource.Event<String>	poll()	Waits for the next SSE and returns an event.
private HttpClient.EventImpl	readEvent(String line)
(package private) EventSourceResponse	readResponse(int method)

Methods inherited from class HttpClient.ChunkedLineReader

hasNext, next

Methods inherited from class HttpClient.ResponseReader

mergeChunks, readBody, readBodyUntilClose, readChunkedBody, readLine, readResponseBody, readResponseHeaders, readResultCode

Methods inherited from class Object

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

Methods inherited from interface Iterator

forEachRemaining, remove

Field Details

keepAlive

private boolean keepAlive

Constructor Details

ServerSentEventsReader

ServerSentEventsReader(Socket socket,
 int bufferSize)
                throws IOException

Throws:

IOException

Method Details

readResponse

EventSourceResponse readResponse(int method)
                          throws IOException,
HttpException

Overrides:

readResponse in class HttpClient.ResponseReader

Throws:

IOException

HttpException

poll

public EventSource.Event<String> poll()

Description copied from interface: EventSource

Waits for the next SSE and returns an event. The method can block for a long time ( determined by server ). It is essential to check for null and EventSource.Event.isEmpty() before processing

Specified by:

poll in interface EventSource<String>

Returns:

the next event from the stream or null, if stream was closed by either party

readEvent

private HttpClient.EventImpl readEvent(String line)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class HttpClient.ChunkedLineReader