argument-passing.scala

trait ServiceA {
  def createA(a: EntityA, cid: CorrelationId): IO[_]
}

trait ClientB {
  def getB(bId: EntityBID, cid: CorrelationId): IO[_]
}

case class ServiceAImpl(clientB: ClientB) extends ServiceA {
  override def createA(a: EntityA, cid: CorrelationId): IO[_] = {
    for {
      entityB    <- clientB.getB(a.idOfB, cid)
      processed  <- somePrivateBusinessLogic(entityB, cid)
      result     <- someMoreBusinessLogic(processed, cid)
      _          <- logger.info(s"Successfully processed entity ${a.id} ", cid)
    } yield result
  }
}


trait Logger {
  def error(msg: String, t: Throwable, cid: CorrelationId): Unit
  def info(msg: String, cid: CorrelationId): Unit = {
    underlyingLogger.info(s"[${cid}] $msg") 
  }
  def debug(msg: String, cid: CorrelationId): Unit
}