SampleFixes.kit

  fun <V> storeDataWithCustomChannelAsync(updateInMemoryCache: Boolean = true, update: (T) -> T, V): Deferred<V> {
    return cache.updateIfPresentAsync { cachedPayload ->
      // Although it's odd to notify before the change is made, the single threaded nature of the blocking cache ensures
      // nothing can read from it until this update completes.
      asyncDataSubscriptionManager.notifyChange(providerId)
      val updatedPayload, channelValue = storeFileCache(cachedPayload, update)
      if (updateInMemoryCache) (updatedPayload, channelValue) else (cachedPayload, channelValue)
    }
  }
    
  fun <V> updateWithCustomChannelIfPresentAsync(update: suspend (T) -> T, V): Deferred<V> {
    return blockingScope.async {
      val updatedValue, channelValue = update(checkNotNull(value) { "Expected to update the cache only after it's been created" })
      value = updatedValue
      channelValue
    }
  }