Roman Gafiyatullin

class BlockingInsideOfActor extends Actor {
  var state = State() // next time I'll use become(newState)...
  def timeout: Timeout = ...
  
  val queue = Queue[(Request, ActorRef)].empty
  
  def pending: Receive = {
     case req: Request =>
      queue.push((req, sender()))
      //log message here 
  }

  def normalContext = {
   //popping queue in order of incoming message
  }
  
  def receive = {
    case req: Request =>
      val futRespData: Future[ResponseData] = processRequest(req) // resp is under a Future.
      val sndr = sender()
      context.become(pending)// catch all messagee whil pending request 
      
      futRespData.onComplete{ tryResutl => 
        tryResutl match {
          
          case Success(...) =>  
              val nextState =if (respData.success) state.incSuccessCount 
              else state.incFailureCount
              
           // response is a function of 'resp'
          sndr ! Response(
                    data = respData, 
                    successCount = nextState.successCount
                    failureCount = failureCount.failureCount)    
                    
   //       state = nextState     
         context.become(normalContext)  
        }
      }
      
  }
}