public interface ChangesFeed
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Will close this feed and interrupt any threads waiting on next()
|
boolean |
isAlive() |
DocumentChange |
next()
Retrieves and removes the head of this changes feed, waiting if necessary until an element becomes available.
|
DocumentChange |
next(long timeout,
TimeUnit unit)
Retrieves and removes the head of this changes feed, waiting up to the specified wait time if necessary for an element to become available.
|
DocumentChange |
poll()
Retrieves and removes the head of this changes feed, do not wait until an element becomes available. returns null if empty
|
int |
queueSize() |
DocumentChange next() throws InterruptedException
InterruptedException
- when this changes feed is closed or otherwise is interruptedDocumentChange poll() throws InterruptedException
InterruptedException
- when this changes feed is closed or otherwise is interruptedDocumentChange next(long timeout, TimeUnit unit) throws InterruptedException
timeout
- unit
- InterruptedException
- when this changes feed is closed or otherwise is interruptedvoid cancel()
boolean isAlive()
int queueSize()
Copyright © 2013. All Rights Reserved.