Caches are tricky - Let Mules Haul its Weight.
To use mules in an existing SBT project with Scala 2.11 or a later version, add the following dependencies to your build.sbt depending on your needs:
libraryDependencies ++= Seq(
"io.chrisdavenport" %% "mules" % "<version>"
)Then the import
import io.chrisdavenport.mules._
import cats.effect.IO
import scala.concurrent.duration._
import cats.effect.unsafe.implicits.globalNow Lets Use What We have built.
val getInserted = for {
cache <- MemoryCache.ofSingleImmutableMap[IO, String, Int](Some(TimeSpec.unsafeFromDuration(1.second)))
_ <- cache.insert("Foo", 1)
value <- cache.lookup("Foo")
} yield value
getInserted.unsafeRunSync
// res0: Option[Int] = Some(1)
val getRemoved = for {
cache <- MemoryCache.ofSingleImmutableMap[IO, String, Int](None)
_ <- cache.insert("Foo", 1)
_ <- cache.delete("Foo")
value <- cache.lookup("Foo")
} yield value
getRemoved.unsafeRunSync
// res1: Option[Int] = None
val getAfterPurged = for {
cache <- MemoryCache.ofSingleImmutableMap[IO, String, Int](Some(TimeSpec.unsafeFromDuration(1.second)))
_ <- cache.insert("Foo", 1)
_ <- IO.sleep(2.seconds)
_ <- cache.purgeExpired
value <- cache.lookupNoUpdate("Foo")
} yield value
getAfterPurged.unsafeRunSync
// res2: Option[Int] = None
val lookupAfterInterval = for {
cache <- MemoryCache.ofSingleImmutableMap[IO, String, Int](Some(TimeSpec.unsafeFromDuration(1.second)))
_ <- cache.insert("Foo", 1)
_ <- IO.sleep(2.seconds)
value <- cache.lookup("Foo")
} yield value
lookupAfterInterval.unsafeRunSync
// res3: Option[Int] = None
