made AStream Sequential

made *io-context* public

Author: richhickey

src/clj/clojure/core.clj

@@ -1299,7 +1299,7 @@
     (. ref (touch))
     (. ref (get)))
 
-(def #^{:private true :tag clojure.lang.Closer} *io-context* nil)
+(def #^{:tag clojure.lang.Closer} *io-context* nil)
 
 (defmacro sync
   "transaction-flags => TBD, pass nil for now
@@ -1437,6 +1437,17 @@
                    eos 
                    (apply f xs)))))))))
 
+(defn map
+  "Returns a lazy seq consisting of the result of applying f to the
+  set of first items of each coll, followed by applying f to the set
+  of second items in each coll, until any one of the colls is
+  exhausted.  Any remaining items in other colls are ignored. Function
+  f should accept number-of-colls arguments."
+  ([f coll] (seq (map-stream f coll)))
+  ([f c1 c2] (seq (map-stream f c1 c2)))
+  ([f c1 c2 c3] (seq (map-stream f c1 c2 c3)))
+  ([f c1 c2 c3 & colls] (seq (apply map-stream f c1 c2 c3 colls))))
+
 (defn mapcat
   "Returns the result of applying concat to the result of applying map
   to f and colls.  Thus function f should return a collection."

src/jvm/clojure/lang/AStream.java

@@ -12,7 +12,7 @@
 
 package clojure.lang;
 
-final public class AStream implements Seqable, Streamable {
+final public class AStream implements Seqable, Streamable, Sequential {
 
     static final ISeq NO_SEQ = new Cons(null, null);
 

src/jvm/clojure/lang/RT.java

@@ -720,7 +720,7 @@ else if(n == 1)
 
 	else if(coll instanceof Sequential)
 		{
-		ISeq seq = ((IPersistentCollection) coll).seq();
+		ISeq seq = RT.seq(coll);
         coll = null;
         for(int i = 0; i <= n && seq != null; ++i, seq = seq.rest())
 			{
@@ -783,7 +783,7 @@ else if(n == 1)
 		}
 	else if(coll instanceof Sequential)
 		{
-		ISeq seq = ((IPersistentCollection) coll).seq();
+        ISeq seq = RT.seq(coll);
         coll = null;
         for(int i = 0; i <= n && seq != null; ++i, seq = seq.rest())
 			{