Java 8 Stream from scala code

Question

I'm trying to use Java 8 Stream from scala code as below and stuck with an compilation error.

any help appreciated!!

def sendRecord(record: String): Unit throws Exception

bufferedReader.lines().forEach(s => sendRecord(s))

Cannot resolve forEach with such signature, expect: Consumer[_ >: String], actual: (Nothing)

PS: though there is some indication that it is almost straight forward like https://gist.github.com/adriaanm/892d6063dd485d7dd221 it doesn't seem to work. I'm running Scala 2.11.8

chengpohi · Accepted Answer · 2016-09-18 07:21:15Z

6

You can convert toiterator to iterate java Stream, like:

import scala.collection.JavaConverters._
bufferedReader.lines().iterator.asScala.forEach(s => sendRecord(s))

answered Sep 18, 2016 at 7:21

chengpohi

14.2k1 gold badge28 silver badges43 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

Łukasz · Accepted Answer · 2017-07-10 06:59:34Z

4

Look at top of the file you linked in your question. It mentions -Xexperimental flag. If you run scala compiler or repl with this flag scala functions will be translated to java equivalents. Another option is to just pass in java function manually.

scala> java.util.stream.Stream.of("asd", "dsa").map(new java.util.function.Function[String, String] { def apply(s: String) = s + "x" }).toArray
res0: Array[Object] = Array(asdx, dsax)

you can also create (implicit) conversion to wrap scala functions for you.

You can also wait for scala 2.12, with this version you won't need the flag anymore.

Update

As scala 2.12 is out, the code in question would just compile normally.

edited Jul 10, 2017 at 6:59

answered Sep 18, 2016 at 9:13

Łukasz

8,6932 gold badges32 silver badges51 bronze badges

Comments

Milad Khajavi · Accepted Answer · 2016-12-30 21:25:35Z

3

In Scala 2.12 you can work with Java streams very easily:

import java.util.Arrays

val stream = Arrays.stream(Array(1, 2, 3, 4, 6, 7))
stream
  .map {
    case i: Int if i % 2 == 0 => i * 2
    case i: Int if i % 2 == 1 => i * 2 + 2
  }
  .forEach(println)

answered Dec 30, 2016 at 21:25

Milad Khajavi

2,85910 gold badges43 silver badges66 bronze badges

Comments

Community · Accepted Answer · 2017-05-23 12:32:11Z

2

The problem is that that expression in scala does not automatically implement the expected java functional interface Consumer.

See these questions for details how to solve it. In Scala 2.12,it will probably work without conversions.

edited May 23, 2017 at 12:32

CommunityBot

11 silver badge

answered Sep 18, 2016 at 8:38

user140547

8,2504 gold badges36 silver badges85 bronze badges

Collectives™ on Stack Overflow

Java 8 Stream from scala code

4 Answers 4

Comments

Update

Comments

Comments

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

4 Answers 4

Comments

Update

Comments

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related