Skip to content

Commit

Permalink
isolated MongoSequence to keep with the pattern of teh rest of Bluepr…
Browse files Browse the repository at this point in the history
…ints.
  • Loading branch information
okram committed Sep 21, 2010
1 parent 4d9b41d commit 9189d65
Show file tree
Hide file tree
Showing 2 changed files with 35 additions and 26 deletions.
Original file line number Original file line Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@


import com.mongodb.*; import com.mongodb.*;
import com.tinkerpop.blueprints.odm.Store; import com.tinkerpop.blueprints.odm.Store;
import com.tinkerpop.blueprints.odm.impls.mongodb.util.MongoSequence;


import java.net.UnknownHostException; import java.net.UnknownHostException;
import java.util.Iterator;
import java.util.Map; import java.util.Map;


/** /**
Expand Down Expand Up @@ -56,29 +56,4 @@ public String toString() {
public void shutdown() { public void shutdown() {
// TODO: what is needed to shutdown a connection in MongoDB? // TODO: what is needed to shutdown a connection in MongoDB?
} }

private class MongoSequence implements Iterator<MongoDocument>, Iterable<MongoDocument> {

private final DBCursor cursor;

public MongoSequence(DBCursor cursor) {
this.cursor = cursor;
}

public boolean hasNext() {
return this.cursor.hasNext();
}

public void remove() {
throw new UnsupportedOperationException();
}

public MongoDocument next() {
return new MongoDocument(this.cursor.next());
}

public Iterator<MongoDocument> iterator() {
return this;
}
}
} }
Original file line number Original file line Diff line number Diff line change
@@ -0,0 +1,34 @@
package com.tinkerpop.blueprints.odm.impls.mongodb.util;

import com.mongodb.DBCursor;
import com.tinkerpop.blueprints.odm.impls.mongodb.MongoDocument;

import java.util.Iterator;

/**
* @author Marko A. Rodriguez (http://markorodriguez.com)
*/
public class MongoSequence implements Iterator<MongoDocument>, Iterable<MongoDocument> {

private final DBCursor cursor;

public MongoSequence(DBCursor cursor) {
this.cursor = cursor;
}

public boolean hasNext() {
return this.cursor.hasNext();
}

public void remove() {
throw new UnsupportedOperationException();
}

public MongoDocument next() {
return new MongoDocument(this.cursor.next());
}

public Iterator<MongoDocument> iterator() {
return this;
}
}

0 comments on commit 9189d65

Please sign in to comment.