将scala函数作为java函数接口参数传递

Question

我有一个java构造函数，它将函数接口作为参数：

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

我试图在scala中使用这个构造函数，但是编译器抱怨说它不能解析构造函数。我尝试过以下几种方法：

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]])

如何将scala函数作为java函数接口参数传递？

Answer 1

您需要创建一个Consumer

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

Answer 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)) )