markglh

// Use Gists to store code you would like to remember later on
console.log(window); // log the "window" object to the console

markglh

import SomeActor.{SendToChild, SendToParent}
import akka.actor.{Actor, ActorRef, ActorSystem, Props}
import akka.event.LoggingReceive
import akka.testkit.{TestActorRef, TestKit, TestProbe}
import org.scalatest.{BeforeAndAfterAll, FreeSpecLike, GivenWhenThen, Matchers}

import scala.concurrent.duration.DurationInt

class ParentChildActorSpec extends TestKit(ActorSystem("some-test-system"))
  with GivenWhenThen

markglh

private def processing(responseCollector: ResponseCollector, manager: ActorRef, retryAttempt: Int = 0): Receive = LoggingReceive {

    def switchToReadyState(latestProcessedSeq: Option[CompoundSequenceNumber]) = {
      context.become(readyToProcess(latestProcessedSeq))
      unstashAll()
    }

    receiveCheckpoint(responseCollector.latestConfirmedEventSeq, Some(manager)).orElse {
      case EventProcessed(sequenceNo, successful) =>