OptionTSupport

OptionTSupport

import cats._
import cats.syntax.all._

import effectie.monix.Effectful._
import effectie.monix._
import effectie.monix.OptionTSupport._

trait Something[F[_]] {
  def foo(a: Int): F[Option[Int]]
  def bar(a: Option[Int]): F[Option[Int]]
}

object Something {
  def apply[F[_]: Something]: Something[F] =
    implicitly[Something[F]]

  implicit def something[F[_]: Fx: Monad]: Something[F] =
    new SomethingF[F]

  final class SomethingF[F[_]: Fx: Monad]
    extends Something[F] {

    def foo(a: Int): F[Option[Int]] = (for {
      x <- a.someTF[F] // == OptionT.liftF(Applicative[F].pure(a))
      y <- (x + 10).someTF[F] // == OptionT.liftF(Applicative[F].pure(x + 10))
      z <- effectOf(y + 100).someT // == OptionT.lieftF(effectOf(y + 100))
    } yield z).value

    def bar(a: Option[Int]): F[Option[Int]] = (for {
      x <- a.optionT[F] // == OptionT(pureOf(a: Option[Int]))
      y <- effectOf((x + 999).some).optionT  // == OptionT(effectOf((x + 999).some)) 
    } yield y).value
  }

}

import monix.eval._
import monix.execution.Scheduler.Implicits.global

Something[Task].foo(1).runSyncUnsafe()
// res1: Option[Int] = Some(value = 111)
Something[Task].foo(10).runSyncUnsafe()
// res2: Option[Int] = Some(value = 120)

Something[Task].bar(1.some).runSyncUnsafe()
// res3: Option[Int] = Some(value = 1000)
Something[Task].bar(none[Int]).runSyncUnsafe()
// res4: Option[Int] = None