Interface QuerySubscriptionService<T>

interface QuerySubscriptionService<T> {
    createQueryBuilder(): IQueryBuilder<T>;
    createSubscription(cte: CTE<T>): QuerySubscriptionResult<T>;
    fetchSnapshot(cte: CTE<T>): T[];
    subscribe(
        cte: CTE<T>,
        callbacks: QuerySubscriptionCallback<T>,
    ): UnsubscribeFn;
}