diff --git a/jOOQ/src/main/java/org/jooq/Queries.java b/jOOQ/src/main/java/org/jooq/Queries.java index 78b6ebd00d..d7fa2bd1ef 100644 --- a/jOOQ/src/main/java/org/jooq/Queries.java +++ b/jOOQ/src/main/java/org/jooq/Queries.java @@ -40,15 +40,24 @@ */ package org.jooq; +import java.util.stream.Stream; + /** * A wrapper for a collection of queries. * * @author Lukas Eder */ -public interface Queries { +public interface Queries extends Iterable { /** * The wrapped collection of queries. */ Query[] queries(); + + + /** + * The wrapped collection of queries. + */ + Stream stream(); + } diff --git a/jOOQ/src/main/java/org/jooq/impl/QueriesImpl.java b/jOOQ/src/main/java/org/jooq/impl/QueriesImpl.java index 1429b92d30..f8cf880f41 100644 --- a/jOOQ/src/main/java/org/jooq/impl/QueriesImpl.java +++ b/jOOQ/src/main/java/org/jooq/impl/QueriesImpl.java @@ -41,6 +41,8 @@ package org.jooq.impl; import java.util.Collection; +import java.util.Iterator; +import java.util.stream.Stream; import org.jooq.Queries; import org.jooq.Query; @@ -61,6 +63,20 @@ final class QueriesImpl implements Queries { return queries.toArray(new Query[0]); } + @SuppressWarnings({ "unchecked", "rawtypes" }) + @Override + public final Iterator iterator() { + return (Iterator) queries.iterator(); + } + + + @SuppressWarnings({ "unchecked", "rawtypes" }) + @Override + public final Stream stream() { + return (Stream) queries.stream(); + } + + @Override public String toString() { StringBuilder sb = new StringBuilder();