如何在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