如何在Java中实例化和填充Scala流？

Question

我有一个需要从Java代码调用的Scala函数foo(bs : Stream[Bar]) : Bat。如何在Java中创建“bs”流（Stream[Bar]）并延迟生成其Bar对象？

Answer 1

根据什么需要是在流，这可能是最简单的创建一个java.util.Iterator，然后将其转换为一个Stream通过scala.collection.Iterator：

import scala.collection.JavaConverters; 
import scala.collection.immutable.Stream; 

... 

List<String> list = new ArrayList<String>(); 

\\ Fill the list somehow... 

Iterator<String> it = list.iterator(); 

Stream<String> stream = JavaConverters.asScalaIteratorConverter(it) 
             .asScala().toStream(); 

迭代器当然不一定来自集合 - 我们可以通过实现我们自己的迭代器来轻松创建无限流：

Stream<String> stream = JavaConverters.asScalaIteratorConverter(
    new Iterator<String>() { 
    int i = 0; 
    public boolean hasNext() { return true; } 
    public void remove() { throw new UnsupportedOperationException(); } 
    public String next() { return Integer.toString(i++); } 
    } 
).asScala().toStream(); 

它不像Stream.iterate(0)(_ + 1).map(_.toString)那样漂亮，但它的工作原理。

Answer 2

你试过

scala.collection.immutable.Stream bs = new scala.collection.immutable.Stream() 

？

Answer 3

最好的方法是使用Stream对象伴侣提供的工厂之一。对于他们中最有用的，你也需要实现Function1，这可以通过扩展AbstractFunction1来完成。

下面是一个例子：

import scala.collection.immutable.Stream; 
import scala.runtime.AbstractFunction1; 

public class Ex { 
    public Stream<Integer> stream = Stream.iterate(0, new Increment()); 
} 

class Increment extends AbstractFunction1<Integer, Integer> { 
    public Integer apply(Integer v1) { 
     return v1 + 1; 
    } 
} 

Answer 4

我知道你在寻找scala流，但也有功能性的java：http://functionaljava.googlecode.com/svn/artifacts/3.0/javadoc/fj/data/Stream.html