cache that handles its own updates

BlerfCache.scala

case class BlerfCache(
    blerfs: Ref[IO, Map[Id, Blerf]],
    private val getBlerfMap: IO[Map[Id, Blerf]],
) extends Logging {
  def updateBlerfs: IO[Unit] = getBlerfMap.flatMap(b => blerfs.set(b))

  def refreshCache: IO[Unit] =
    Stream
      .repeatEval(logger.debug("refreshing blerf...") *> updateBlerfs)
      .metered(5.minutes)
      .compile
      .drain
}
object BlerfCache {
  def getBlerfMap(client: Client[IO]): IO[Map[Id, Blerf]] =
    client
      .expect[BlerfResp]("www.blerf.ca/fake/endpoint")
      .flatMap(br => br.toBlerfMap)

  def build(client: Client[IO]): Resource[IO, BlerfCache] = {
    val blerf: IO[BlerfCache] = Ref.ofEffect(getBlerfMap(client)).map(BlerfCache(_, getBlerfMap(client)))
    val updatingBlerf       = Resource.eval(blerf).flatMap(b => b.refreshCache.background.map(_ => b))
    updatingBlerf
  }
}