Obtaining cats.effect.Ref that is always set to a let element of fs2.Stream

ref.scala

  /**
   * Returns a resource that contains a ref set to the last element of the stream.
   */
  def streamRef[F[_] : Async, A](stream: Stream[F, A], default: A): Resource[F, RefSource[F, A]] = {
    val ri = for
      ref <- Ref.of(default)
      interrupt <- SignallingRef.of(false)

      _ <- Async[F].start {
        stream
          .foreach(ref.set)
          .interruptWhen(interrupt)
          .compile.drain
      }
    yield (ref, interrupt)

    Resource
      .make(ri)(_._2.set(true))
      .map(_._1)
  }