                 {
                 debugLog(.cache, ["Cache hit for", cacheEntry])
 
-                let processed = processAndCache(
+                let processed = Pipeline.processAndCache(
                     .success(result),
                     using: stagesAndEntries.suffix(from: index + 1))
 

        }

    // Runs on a background queue
    private func processAndCache<StagesAndEntries: Collection>(
            _ rawResponse: Response,
            using stagesAndEntries: StagesAndEntries)
        -> Response

        }

    // Runs on a background queue
    private static func cacheLookup(using stagesAndEntries: [StageAndEntry]) -> Entity<Any>?
        {
        for (index, (_, cacheEntry)) in stagesAndEntries.enumerated().reversed()
            {
