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