जावा में स्कैला स्ट्रीम को तुरंत चालू और पॉप्युलेट कैसे करें?

Question

मेरे पास एक स्कैला फ़ंक्शन foo(bs : Stream[Bar]) : Bat है जिसे मुझे जावा कोड से कॉल करने की आवश्यकता है। मैं जावा में "बीएस" स्ट्रीम (Stream[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

मुझे पता है तुम स्केला धारा देख रहे थे लेकिन वहाँ कार्यात्मक जावा भी है: http://functionaljava.googlecode.com/svn/artifacts/3.0/javadoc/fj/data/Stream.html