Skip to content

Commit

Permalink
remove some objects and methods
Browse files Browse the repository at this point in the history
prepare next version
  • Loading branch information
xuwei-k committed Aug 8, 2023
1 parent f21330d commit e5f3c2e
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 26 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -119,24 +119,6 @@ trait TaskInterpretation extends TaskTypes {
case Right(a) => Eff.pure(a)
}

/**
* Memoize task values using a memoization effect
*
* if this method is called with the same key the previous value will be returned
*/
def taskMemoized[R, A](key: AnyRef, e: Eff[R, A])(implicit task: Task /= R, m: Memoized |= R): Eff[R, A] =
MemoEffect.getCache[R].flatMap(cache => taskMemo(key, cache, e))

def runTaskMemo[R, U, A](cache: Cache)(effect: Eff[R, A])(implicit m: Member.Aux[Memoized, R, U], task: Task |= U): Eff[U, A] = {
interpret.translate(effect)(new Translate[Memoized, U] {
def apply[X](mx: Memoized[X]): Eff[U, X] =
mx match {
case Store(key, value) => TaskCreation.taskDelay(cache.memo(key, value()))
case GetCache() => TaskCreation.taskDelay(cache)
}
})
}

implicit val taskSequenceCached: SequenceCached[Task] = new SequenceCached[Task] {
def get[X](cache: Cache, key: AnyRef): Task[Option[X]] =
Task.delay(cache.get(key)).executeAsync
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,9 +21,6 @@ final class TaskOps[R, A](private val e: Eff[R, A]) extends AnyVal {
def asyncBoundary(s: Scheduler)(implicit task: Task |= R): Eff[R, A] =
e.flatMap(a => TaskEffect.asyncBoundary(s).map(_ => a))

def runTaskMemo[U](cache: Cache)(implicit m: Member.Aux[Memoized, R, U], task: Task |= U): Eff[U, A] =
TaskEffect.runTaskMemo(cache)(e)

def taskAttempt(implicit task: Task /= R): Eff[R, Throwable Either A] =
TaskInterpretation.taskAttempt(e)

Expand Down
6 changes: 1 addition & 5 deletions shared/src/main/scala/org/atnos/eff/package.scala
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,6 @@ package object eff {
type |=[M[_], R] = MemberIn.|=[M, R]

object eff extends EffCreation with EffInterpretation
object validate extends ValidateCreation with ValidateInterpretation
object choose extends ChooseCreation with ChooseInterpretation
object safe extends SafeCreation with SafeInterpretation
object batch extends Batch
object interpret extends Interpret with Batch
object interpret extends Interpret

}

0 comments on commit e5f3c2e

Please sign in to comment.