koen-dejonghe · October 19, 2018 11:48
diff --git a/am4.scala b/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)
 }
	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)
	}