private def processCallbacks()

in client/src/main/scala/org/apache/toree/kernel/protocol/v5/client/execution/DeferredExecution.scala [109:125]

17 lines of code
8 McCabe index (conditional complexity)


  private def processCallbacks(): Unit = {
    (executeReplyOption, executeResultOption) match {
      case (Some(executeReply), Some(executeResult)) if executeReply.status.equals("error") =>
        callErrorCallbacks(executeReply)
      case (Some(executeReply), Some(executeResult)) if executeReply.status.equals("ok") =>
        callResultCallbacks(executeResult)
        callSuccessCallbacks(executeReply)
      case (Some(executeReply), None) if executeReply.status.equals("ok") =>
        callSuccessCallbacks(executeReply)
      case value =>
        logger.debug(
          s"""|Did not invoke client callbacks.
              |ExecuteReply was: ${executeReplyOption}
              |ExecuteResult was: ${executeResultOption}
           """.stripMargin.trim)
    }
  }