Scala Actor: ReceiveTimeout with Param

Question

是否可以将参数传递给 ReceiveTimeout？我有以下代码：

case ReceiveTimeout =>
      self ! BuildJobEvents(asperaClient.getWorkOrder(workOrderID), dateTime)

当我尝试传递参数时，但这无效。我查看了这里的文档，也没有看到任何关于使用参数的内容。是否可以将参数传递给接收超时？如果没有，我将如何解决这个问题？

编辑

我有一个参与者系统，可以将事件记录到表中。每个事件都有一个时间戳，用于记录其发生的时间。我需要沿链传递此时间戳，以便我可以使用它来确定数据（具有updated_at时间戳）是否实际更改。

前任：当我调用 API 服务时，假设我收到如下事件：

Item {
  event1 {
    stated: 5:00pm,
    completed: 5:10pm
  },
  event1 {
    stated: 5:10pm
  }
  data: data
  updated_at: 5:11pm
}

我想在这里记录事件 1 和事件 2。我还想在消息中传递 dateTime 值 5：11 pm，以便我们可以将其用于下一次调用：

Item {
  event1 {
    stated: 5:00pm,
    completed: 5:10pm
  },
  event1 {
    stated: 5:10pm,
    completed: 5:12pm
  }
  data: data
  updated_at: 5:12pm
}

在这种情况下，我不想记录 event1，因为时间戳在 5：11 之前，因此，参与者已经记录了它。不过我会再次记录事件 2。

Answer 1

您可能正在寻找可用于实现轻量级状态机context.become。

class MyActor extends Actor {
  override def receive: Receive = {
    case something =>
      context.setReceiveTimeout(5.seconds)
      context.become(waitForTimeout(something))
  }
  private[this] def waitForTimeout(param: Any): Receive = {
    case ReceiveTimeout =>
      // do something with something
  }
}

如果你混合FSM特质，你有更多的可能性。

编辑

阅读您的事件示例，也许是这样的？

private def receiveNextEvent(lastTimestamp: DateTime): Receive = {
  case event =>
   if (event.stated > lastTimestamp) {
     logEvent(event)
     context.become(receiveNextEvent(event.stated)
   }
}