Làm thế nào để khởi tạo và điền một Dòng Scala trong Java?

Question

Tôi có chức năng Scala foo(bs : Stream[Bar]) : Bat mà tôi cần gọi từ mã Java. Làm cách nào để tạo luồng "bs" (Stream[Bar]) trong Java và tạo ra các đối tượng Bar của nó một cách lười biếng?

Answer 1

Tùy thuộc vào những gì cần phải được trong dòng, nó có thể là dễ nhất để tạo một java.util.Iterator và sau đó chuyển đổi này cho một người Stream qua một 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(); 

Trình lặp không nhất thiết phải xuất phát từ bộ sưu tập — chúng ta có thể dễ dàng tạo luồng vô hạn bằng cách triển khai trình lặp của riêng chúng ta:

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(); 

Nó không đẹp như một cái gì đó như Stream.iterate(0)(_ + 1).map(_.toString), nhưng nó hoạt động.

Answer 2

Các bạn đã thử

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

?

Answer 3

Cách tốt nhất là sử dụng một trong các nhà máy có sẵn trên Stream đối tượng đồng hành. Để sử dụng chúng hữu ích nhất, bạn cũng cần triển khai Function1, có thể thực hiện bằng cách mở rộng AbstractFunction1.

Dưới đây là một ví dụ:

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

Tôi biết bạn đang tìm kiếm luồng scala nhưng cũng có chức năng java: http://functionaljava.googlecode.com/svn/artifacts/3.0/javadoc/fj/data/Stream.html