         }
     }
 
-    return cachedDataSteam.tryMap(validateByDateResultBinder)
+    return steam.tryMap(validateByDateResultBinder)
 }

    let strategy        = cacheArgs.strategy

    let cachedDataStream: AsyncStream<(DataRequestContext<DataLoadContext>, Data), Any, ErrorWithContext> =
        loadFreshCachedDataWithUpdateDate(cache.cachedDataStreamFor(key: cacheKey), strategy: strategy)

    switch cacheArgs.strategy {
    case .networkFirst:

    }
}

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

