HttpClient.ServerSentEventsReader

java.lang.Object
- one.nio.http.HttpClient.ResponseReader
- - one.nio.http.HttpClient.ChunkedLineReader
  - - one.nio.http.HttpClient.ServerSentEventsReader

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.util.Iterator<java.lang.String>, EventSource<java.lang.String>

Enclosing class:

HttpClient
```
class HttpClient.ServerSentEventsReader
extends HttpClient.ChunkedLineReader
implements EventSource<java.lang.String>
```

Nested Class Summary
- Nested classes/interfaces inherited from interface one.nio.http.EventSource
  EventSource.Event<D>

Field Summary

Fields
Modifier and Type Field Description

private boolean keepAlive
- Fields inherited from class one.nio.http.HttpClient.ResponseReader
  buf, length, pos, socket

Constructor Summary

Constructors
Constructor Description

ServerSentEventsReader(Socket socket, int bufferSize)

Method Summary

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

Methods inherited from class one.nio.http.HttpClient.ChunkedLineReader
hasNext, next

Methods inherited from class one.nio.http.HttpClient.ResponseReader
mergeChunks, readBody, readBodyUntilClose, readChunkedBody, readLine, readResponseBody, readResponseHeaders, readResultCode

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator
forEachRemaining, remove

- Field Detail
  - keepAlive
```
private boolean keepAlive
```
- Constructor Detail
  - ServerSentEventsReader
```
ServerSentEventsReader(Socket socket,
                       int bufferSize)
                throws java.io.IOException
```
    Throws:
    
    java.io.IOException
- Method Detail
  - readResponse
```
EventSourceResponse readResponse(int method)
                          throws java.io.IOException,
                                 HttpException
```
    Overrides:
    
    readResponse in class HttpClient.ResponseReader
    
    Throws:
    
    java.io.IOException
    
    HttpException
  - poll
```
public EventSource.Event<java.lang.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<java.lang.String>
    
    Returns:
    
    the next event from the stream or null, if stream was closed by either party
  - readEvent
```
private HttpClient.EventImpl readEvent(java.lang.String line)
```
  - close
```
public void close()
```
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Specified by:
    
    close in interface java.io.Closeable
    
    Overrides:
    
    close in class HttpClient.ChunkedLineReader