(queryClient: QueryClient)
| 121 | yield* Effect.forEach( |
| 122 | keys, |
| 123 | (queryKey) => Effect.promise(() => queryClient.invalidateQueries({ queryKey }, { updateMeta: { span } })), |
| 124 | { discard: true, concurrency: "unbounded" } |
| 125 | ) |
| 126 | }) |
| 127 | .pipe(Effect.orDie) |
| 128 | }) |
| 129 | |
| 130 | const fullQueryKey = ( |
| 131 | q: { readonly queryKeyProjectionHash?: string }, |
| 132 | queryKey: ReadonlyArray<unknown>, |
| 133 | input: unknown |
| 134 | ) => q.queryKeyProjectionHash === undefined ? [...queryKey, input] : [...queryKey, q.queryKeyProjectionHash, input] |
| 135 | |
| 136 | export const makeTanstackQueryCacheUpdater = (queryClient: QueryClient): QueryCacheUpdater => ({ |
| 137 | update: <I, A, E, R, Request extends Req, Name extends string>( |
| 138 | _registry: ReturnType<typeof injectRegistry>, |
| 139 | query: RequestHandlerWithInput<I, A, E, R, Request, Name>, |
| 140 | input: I, |
no test coverage detected
searching dependent graphs…