Revision: 2375
http://archive-access.svn.sourceforge.net/archive-access/?rev=2375&view=rev
Author: bradtofel
Date: 2008-07-01 16:46:33 -0700 (Tue, 01 Jul 2008)
Log Message:
-----------
INITIAL REV: Iterator implementation that uses an ObjectFilter to determine if entries from the internal delegate are included.
Added Paths:
-----------
trunk/archive-access/projects/wayback/wayback-core/src/main/java/org/archive/wayback/util/ObjectFilterIterator.java
Added: trunk/archive-access/projects/wayback/wayback-core/src/main/java/org/archive/wayback/util/ObjectFilterIterator.java
===================================================================
--- trunk/archive-access/projects/wayback/wayback-core/src/main/java/org/archive/wayback/util/ObjectFilterIterator.java (rev 0)
+++ trunk/archive-access/projects/wayback/wayback-core/src/main/java/org/archive/wayback/util/ObjectFilterIterator.java 2008-07-01 23:46:33 UTC (rev 2375)
@@ -0,0 +1,109 @@
+/* ObjectFilterIterator
+ *
+ * $Id$
+ *
+ * Created on 2:55:48 PM Jun 28, 2008.
+ *
+ * Copyright (C) 2008 Internet Archive.
+ *
+ * This file is part of wayback.
+ *
+ * wayback is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU Lesser Public License as published by
+ * the Free Software Foundation; either version 2.1 of the License, or
+ * any later version.
+ *
+ * wayback is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Lesser Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser Public License
+ * along with wayback; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+ */
+package org.archive.wayback.util;
+
+import java.io.IOException;
+import java.util.Iterator;
+import java.util.NoSuchElementException;
+
+/**
+ *
+ *
+ * @author brad
+ * @version $Date$, $Revision$
+ */
+public class ObjectFilterIterator<T> implements CloseableIterator<T> {
+
+ ObjectFilter<T> filter = null;
+ Iterator<T> itr = null;
+ boolean aborted = false;
+ T cachedNext = null;
+ public ObjectFilterIterator(CloseableIterator<T> itr,
+ ObjectFilter<T> filter) {
+ this.itr = itr;
+ this.filter = filter;
+ }
+
+ /* (non-Javadoc)
+ * @see java.util.Iterator#hasNext()
+ */
+ public boolean hasNext() {
+ if(cachedNext != null) {
+ return true;
+ }
+ if(aborted) {
+ return false;
+ }
+ while(cachedNext == null) {
+ if(!itr.hasNext()) {
+ aborted = true;
+ close();
+ return false;
+ }
+ T maybeNext = itr.next();
+ int ruling = filter.filterObject(maybeNext);
+ if(ruling == ObjectFilter.FILTER_ABORT) {
+ aborted = true;
+ close();
+ return false;
+ } else if(ruling == ObjectFilter.FILTER_INCLUDE) {
+ cachedNext = maybeNext;
+ }
+ }
+ return true;
+ }
+
+ public void close() {
+ if(itr instanceof CloseableIterator) {
+ CloseableIterator<T> citr =
+ (CloseableIterator<T>) itr;
+ try {
+ citr.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ /* (non-Javadoc)
+ * @see java.util.Iterator#next()
+ */
+ public T next() {
+ if(cachedNext == null) {
+ throw new NoSuchElementException("call hasNext first!");
+ }
+ T o = cachedNext;
+ cachedNext = null;
+ return o;
+ }
+
+ /* (non-Javadoc)
+ * @see java.util.Iterator#remove()
+ */
+ public void remove() {
+ // TODO Auto-generated method stub
+
+ }
+}
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
