TestingTemporaries

gistfile1.scala

case class TestingTemporaries(buffer: java.util.concurrent.ConcurrentLinkedQueue[LocalPath])

object TestingTemporaries {
  val registered: java.util.concurrent.atomic.AtomicReference[TestingTemporaries] =
    new java.util.concurrent.atomic.AtomicReference[TestingTemporaries]


  def localPath: RIO[LocalPath] = ResultT.io {
    if (registered.compareAndSet(null, TestingTemporaries(new java.util.concurrent.ConcurrentLinkedQueue)))
      Runtime.getRuntime.addShutdownHook(new Thread(new Runnable {
        def run: Unit = {
          // TODO delete all the things
        }
      }))
    val temporaries = registered.get
    val p = LocalPath(uniqueLocalPath)
    temporaries.buffer.add(p)
    p
  }
}