[Gzz-commits] storm/org/nongnu/storm/impl AsyncSetCollector.java

[Benja Fallenstein]

CVSROOT:        /cvsroot/storm
Module name:    storm
Changes by:     Benja Fallenstein <address@hidden>      03/04/25 06:53:56

Modified files:
        org/nongnu/storm/impl: AsyncSetCollector.java 

Log message:
        try fix

CVSWeb URLs:
http://savannah.gnu.org/cgi-bin/viewcvs/storm/storm/org/nongnu/storm/impl/AsyncSetCollector.java.diff?tr1=1.6&tr2=1.7&r1=text&r2=text

Patches:
Index: storm/org/nongnu/storm/impl/AsyncSetCollector.java
diff -u storm/org/nongnu/storm/impl/AsyncSetCollector.java:1.6 
storm/org/nongnu/storm/impl/AsyncSetCollector.java:1.7
--- storm/org/nongnu/storm/impl/AsyncSetCollector.java:1.6      Tue Apr 22 
09:01:21 2003
+++ storm/org/nongnu/storm/impl/AsyncSetCollector.java  Fri Apr 25 06:53:56 2003
@@ -152,6 +152,9 @@
                public boolean hasNext() {
                    if(!queue.isEmpty())
                        return true;
+                   else if(isFinished())
+                       return false;
+
                    synchronized(queue) {
                        try {
                            queue.wait();
@@ -160,9 +163,11 @@
                    return !queue.isEmpty();
                }
                public Object next() {
-                   if(!queue.isEmpty()) {
+                   if(!queue.isEmpty())
                        return queue.remove(0);
-                   }
+                   else if(isFinished())
+                       throw NoSuchElementException();
+
                    synchronized(queue) {
                        try {
                            queue.wait();