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

Question

我有一个Scala函数foo(bs : Stream[Bar]) : Bat,我需要从Java代码调用.如何Stream[Bar]在Java中创建"bs"Stream()并懒惰地生成其Bar对象？

Answer 1

最好的方法是使用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 2

根据流中的需要,最简单的方法是创建一个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),但它有效.