org.synchronoss.cpo
Class CpoBlockingResultSet<E>
java.lang.Object
org.synchronoss.cpo.CpoBlockingResultSet<E>
- All Implemented Interfaces:
- java.lang.Iterable<E>, java.util.Iterator<E>, CpoResultSet<E>
public class CpoBlockingResultSet<E>
- extends java.lang.Object
- implements CpoResultSet<E>, java.util.Iterator<E>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CpoBlockingResultSet
public CpoBlockingResultSet(int capacity)
put
public void put(E e)
throws java.lang.InterruptedException
- Specified by:
put
in interface CpoResultSet<E>
- Throws:
java.lang.InterruptedException
hasNext
public boolean hasNext()
- Specified by:
hasNext
in interface java.util.Iterator<E>
size
public int size()
- Specified by:
size
in interface CpoResultSet<E>
remove
public void remove()
- Specified by:
remove
in interface java.util.Iterator<E>
next
public E next()
throws java.util.NoSuchElementException
- Specified by:
next
in interface java.util.Iterator<E>
- Throws:
java.util.NoSuchElementException
iterator
public java.util.Iterator<E> iterator()
- Specified by:
iterator
in interface java.lang.Iterable<E>
take
public E take()
throws java.lang.InterruptedException
- Specified by:
take
in interface CpoResultSet<E>
- Throws:
java.lang.InterruptedException
isDone
public boolean isDone()
setDone
public void setDone(boolean done)
cancel
public void cancel()
- Specified by:
cancel
in interface CpoResultSet<E>
getFetchSize
public int getFetchSize()
- Specified by:
getFetchSize
in interface CpoResultSet<E>
Copyright © 2010. All Rights Reserved.