org.synchronoss.cpo
Class CpoBlockingResultSet<E>

Package class diagram package CpoBlockingResultSet
java.lang.Object
  extended by 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>


Constructor Summary
CpoBlockingResultSet(int capacity)
           
CpoBlockingResultSet(int capacity, boolean fair)
           
CpoBlockingResultSet(int capacity, boolean fair, java.util.Collection<? extends E> c)
           
 
Method Summary
 void cancel()
           
 int getFetchSize()
           
 boolean hasNext()
           
 boolean isDone()
           
 java.util.Iterator<E> iterator()
           
 E next()
           
 void put(E e)
           
 void remove()
           
 void setDone(boolean done)
           
 int size()
           
 E take()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CpoBlockingResultSet

public CpoBlockingResultSet(int capacity)

CpoBlockingResultSet

public CpoBlockingResultSet(int capacity,
                            boolean fair,
                            java.util.Collection<? extends E> c)

CpoBlockingResultSet

public CpoBlockingResultSet(int capacity,
                            boolean fair)
Method Detail

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 © 2009. All Rights Reserved.