public class StreamingChangesResult extends Object implements Serializable, Iterable<DocumentChange>, Closeable
Constructor and Description |
---|
StreamingChangesResult(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
HttpResponse response) |
Modifier and Type | Method and Description |
---|---|
void |
abort()
Aborts the stream immediately
|
void |
close() |
long |
getLastSeq()
This method can only be called after stream is fully red
|
Iterator<DocumentChange> |
iterator() |
public StreamingChangesResult(com.fasterxml.jackson.databind.ObjectMapper objectMapper, HttpResponse response)
public Iterator<DocumentChange> iterator()
iterator
in interface Iterable<DocumentChange>
public void abort()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public long getLastSeq()
Copyright © 2013. All Rights Reserved.