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