Pass scala функция като java функционален интерфейс аргумент - java, скала, функционално програмиране

Имам конструктор Java, който приема функционален интерфейс като параметър:

public ConsumerService(QueueName queue, Consumer<T> function) {
super(queue);
this.function = function;
}

Опитвам се да използвам този конструктор в скала, но компилаторът се оплаква, казвайки, че не може да разреши конструктора. Опитах по следните начини:

val consumer = new ConsumerService[String](QueueName.CONSUME, this.process _)
val consumer = new ConsumerService[String](QueueName.PRODUCE, (s: String) => this.process(s))

Аз също се опитах да прехвърлям функцията по време на изпълнение - но това ме оставя с ClassCastException:

val consumer = new ConsumerService[String](QueueName.CONSUME, (this.process _).asInstanceOf[Consumer[String]])

Как мога да предам функция скала като параметър на функционален интерфейс на Java?

Отговори:

7 за отговор № 1

Трябва да създадете a Consumer:

val consumer = new ConsumerService[String](QueueName.CONSUME,
new Consumer[String]() { override def accept(s: String) = process(s) })

---

0 за отговор № 2

Друг начин е да използвате следната библиотека:

https://github.com/scala/scala-java8-compat.

С това във вашия проект, след като импортирате:

import scala.compat.java8.FunctionConverters._

сега можете да напишете:

asJavaConsumer[String](s => process(s))

който във вашия код трябва да върви така:

val consumer = new ConsumerService[String]( QueueName.CONSUME, asJavaConsumer[String](s => process(s)) )

---