TomLous · April 10, 2018 11:55 · TomLous · Apr 10, 2018 · TomLous · Apr 10, 2018
diff --git a/parallel-datafiniti-map-cats.scala b/parallel-datafiniti-map-cats.scala
    import scala.util._
    import scala.concurrent._
    import scala.concurrent.duration.Duration
    import scala.concurrent.ExecutionContext.Implicits.global

    import com.datlinq.datafiniti.response.DatafinitiError
    import com.datlinq.datafiniti.config.DatafinitiAPITypes.Businesses

    import cats.implicits._
    import org.json4s._
    
    // Two ok ids's two not ok
    val ids:List[String] = List("AWEF3R5B3-Khe5l_drZz","AWHMSleZIxWefVJwzAKh","ccc", "ddd")

     /**
      * Why cats traverse?
      * Converting a List[Strings] to a List[Futures] is possible, but rather unwieldy in handling
      * Given a list of ids (List[String]) and a fuction String => Future[_] traverse gives you a Future[List[_]]
      *
      * caveat: Will compile, but unfortunately you have to define the type if you do't want Intellij to freak out (https://youtrack.jetbrains.com/issue/SCL-10259)
     */
    val action:Future[List[(String, Either[DatafinitiError, JValue])]] = ids.traverse(
      id => apiv4.recordById(id, Businesses).value.map(id -> _)
    )

    // side effect on complete
    action.onComplete{
      // if the master future succeeds
      case Success(list) => list.foreach{
              // the id, jvalue tupple for successful call
              case (id, Right(jvalue)) => println(s"$id: " + (jvalue \ "name").extract[String])
                // the datafiniti error when call fails
              case (id, Left(e)) => println(s"$id: ${e.message}")
            }
      // if the future fails (network issue, api down, timouts etc)
      case Failure(f) => println(f.getMessage)
    }

    // The result if you don't want to use side effects from onComplete (use recover, transform etc)
    val res:List[(String,Either[DatafinitiError,JValue])] = Await.result(action, Duration.Inf)


    println(res)
	import scala.util._
	import scala.concurrent._
	import scala.concurrent.duration.Duration
	import scala.concurrent.ExecutionContext.Implicits.global

	import com.datlinq.datafiniti.response.DatafinitiError
	import com.datlinq.datafiniti.config.DatafinitiAPITypes.Businesses

	import cats.implicits._
	import org.json4s._

	// Two ok ids's two not ok
	val ids:List[String] = List("AWEF3R5B3-Khe5l_drZz","AWHMSleZIxWefVJwzAKh","ccc", "ddd")

	/**
	* Why cats traverse?
	* Converting a List[Strings] to a List[Futures] is possible, but rather unwieldy in handling
	* Given a list of ids (List[String]) and a fuction String => Future[_] traverse gives you a Future[List[_]]
	*
	* caveat: Will compile, but unfortunately you have to define the type if you do't want Intellij to freak out (https://youtrack.jetbrains.com/issue/SCL-10259)
	*/
	val action:Future[List[(String, Either[DatafinitiError, JValue])]] = ids.traverse(
	id => apiv4.recordById(id, Businesses).value.map(id -> _)
	)

	// side effect on complete
	action.onComplete{
	// if the master future succeeds
	case Success(list) => list.foreach{
	// the id, jvalue tupple for successful call
	case (id, Right(jvalue)) => println(s"$id: " + (jvalue \ "name").extract[String])
	// the datafiniti error when call fails
	case (id, Left(e)) => println(s"$id: ${e.message}")
	}
	// if the future fails (network issue, api down, timouts etc)
	case Failure(f) => println(f.getMessage)
	}

	// The result if you don't want to use side effects from onComplete (use recover, transform etc)
	val res:List[(String,Either[DatafinitiError,JValue])] = Await.result(action, Duration.Inf)


	println(res)