     let strategy        = cacheArgs.strategy
 
     let cachedDataStream: AsyncStream<(DataRequestContext<DataLoadContext>, Data), Any, ErrorWithContext> =
-        loadFreshCachedDataWithUpdateDate(cache.cachedDataStreamFor(key: cacheKey), strategy: strategy)
+        freshCachedData(from: cache.cachedDataStreamFor(key: cacheKey), strategy: strategy)
 
     switch cacheArgs.strategy {
     case .networkFirst:

        }
    }

    return cachedDataSteam.tryMap(validateByDateResultBinder)
}

    }
}

private func freshCachedData<DataLoadContext>(
    from steam: AsyncStream<(date: Date, data: Data), Any, ErrorWithContext>,
    strategy  : CacheStrategy) -> AsyncStream<(DataRequestContext<DataLoadContext>, Data), Any, ErrorWithContext> {

    let validateByDateResultBinder = { (cachedData: (date: Date, data: Data)) -> Result<(DataRequestContext<DataLoadContext>, Data), ErrorWithContext> in

