cultureofone

import cats.effect.ExitCode
import monix.eval.{Task, TaskApp}
import monix.execution.atomic.Atomic

class MtCache[A](ref: Atomic[Map[String, Task[A]]]) {

  def cache(key: String)(task: () => A): Task[A] = {

    ref.transformAndExtract { current =>
      current.get(key) match {