1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
// @ts-nocheckimport { MaybePromise } from '../../core/index.ts';import { RegisterTypeSubscriptionOptions } from '../types.ts';import BaseSubscriptionManager from './base.ts';import SubscriptionManager from './index.ts';export default class TypeSubscriptionManager<ParentShape = unknown> extends BaseSubscriptionManager {    replace: (value: unknown) => void;    refetchParent: () => MaybePromise<void>;    constructor(manager: SubscriptionManager, replace: (value: unknown) => void, refetchParent: () => MaybePromise<void>) {        super(manager);        this.replace = replace;        this.refetchParent = refetchParent;    }    register<T = unknown>(name: string, { filter, invalidateCache, refetch }: RegisterTypeSubscriptionOptions<T, ParentShape> = {}) {        this.addRegistration<T>({            name,            filter,            onValue: (value) => {                if (invalidateCache) {                    invalidateCache(value);                }                if (refetch) {                    let resultOrPromise: MaybePromise<unknown>;                    try {                        resultOrPromise = refetch(value);                    }                    catch (error: unknown) {                        this.manager.handleError(error);                    }                    this.replace(resultOrPromise);                    return resultOrPromise as MaybePromise<void>;                }                return this.refetchParent();            },        });    }}