IssueTracker

Artifact used: androidx.datastore:datastore:1.0.0
Version used: 1.0.0
Theme used: N/A
Devices/Android versions reproduced on: Unit tests

The effect I am trying to achieve is to:
  1. Create a `DataStore` for a particular file, that is shared when needed but is garbage-collectable when no longer needed
  2. Create a new `DataStore` for that file when it has been garbage collected and is once again needed

This is currently difficult because:
  1. Keeping a reference to a `DataStore`'s `scope` prevents it from being garbage collected
  2. The only way to remove a value from `activeFiles` is to cancel the `DataStore`'s `scope`

One potential fix for this is to avoid capturing a strong reference to the `DataStore` or its `downstreamFlow` in the `consumeMessage` callback passed to `SimpleActor`. This would allow keeping a reference to the scope for cancellation while still allowing the DataStore and its value to be garbage-collectable.

The following code illustrates what I would like to do, but it loops forever at MARK A:

  @Test fun test() {
    val scope = CoroutineScope(Dispatchers.IO + SupervisorJob())
    var store: DataStore<Unit>? = DataStoreFactory.create(
      object : Serializer<Unit> {
        override val defaultValue = Unit
        override suspend fun readFrom(input: InputStream) = Unit
        override suspend fun writeTo(t: Unit, output: OutputStream) {
        }
      },
      produceFile = { File("/tmp/foo") },
      scope = scope!!,
    )
    val storeReference = WeakReference(store)
    store = null
    while (storeReference.get() != null) {  // MARK A
      System.gc()
    }
    scope.cancel()
  }