如何定义更简洁的scala函数

Question

我正在使用 akka 库并提供一个部分函数，​​以便由参与者在运行时通过热交换来实现。

akka 热交换采用 PartialFunction[Any, Unit] 形式的参数。我的定义如下：

class Fake1Reader extends AbstractReader {

  def read: PartialFunction[Any, Unit] = {
    case readingRequest: ReadingRequest => {
      var reading: Reading = new ReadingImpl(readingRequest.getResourceId, "payload",
        Calendar.getInstance.getTime,
      readingRequest.getfrequency, readingRequest.getMappingName,
        readingRequest.getClassificationType,
      readingRequest.getReadingRequestId)
      sendConsumeMessage(reading)
    }
  }
}

所以为了使用这个函数，我必须提供一个新的 Fake1Reader().read。

有没有更简洁的方法使用 apply 或扩展 Function 或 PartialFunction 来执行此类？

Answer 1

如果您的 AbstractReader 是无状态的，您可以定义 object 而不是 class 以避免每次使用时创建不必要的对象，并将函数放置在那里作为不可变的val 的。

此外，伴随对象akka.actor.Actor将类型Receive定义为PartialFunction[Any, Unit]的别名，因此您可以编写您的部分功能如下：

package foo    
object Fake1Reader extends AbstractReader {
  import akka.actor.Actor._

  val read: Receive = { 
    case readingRequest: ReadingRequest => /* implementation */
  }
}

用法：

import foo.Fake1Reader._

actorRef ! HotSwap(read)

Answer 2

顺便说一句，这减少了重复的苦差事：

case readingRequest: ReadingRequest => {
  import readingRequest._
  var reading: Reading = new ReadingImpl(getResourceId, "payload",
    Calendar.getInstance.getTime,
  getfrequency, getMappingName,
    getClassificationType,
  getReadingRequestId)
  sendConsumeMessage(reading)
}