am4.scala

def startPoint(batch: (Variable, Variable)): Receive = {
  case msg @ (Start | _: Backward) =>  
    if (msg == Start) { // new epoch
      ...
    }
    val (x, y) = batch
    wire.next ! Forward(x)
    context become endPoint(y)
}