UNPKG

1.66 kBTypeScriptView Raw
1import { NgZone } from '@angular/core';
2import { Observable, SchedulerAction, SchedulerLike, Subscription } from 'rxjs';
3import * as i0 from "@angular/core";
4/**
5 * Schedules tasks so that they are invoked inside the Zone that is passed in the constructor.
6 */
7export declare class ɵZoneScheduler implements SchedulerLike {
8 private zone;
9 private delegate;
10 constructor(zone: any, delegate?: any);
11 now(): any;
12 schedule(work: (this: SchedulerAction<any>, state?: any) => void, delay?: number, state?: any): Subscription;
13}
14export declare class ɵAngularFireSchedulers {
15 ngZone: NgZone;
16 readonly outsideAngular: ɵZoneScheduler;
17 readonly insideAngular: ɵZoneScheduler;
18 constructor(ngZone: NgZone);
19 static ɵfac: i0.ɵɵFactoryDeclaration<ɵAngularFireSchedulers, never>;
20 static ɵprov: i0.ɵɵInjectableDeclaration<ɵAngularFireSchedulers>;
21}
22export declare function observeOutsideAngular<T>(obs$: Observable<T>): Observable<T>;
23export declare function observeInsideAngular<T>(obs$: Observable<T>): Observable<T>;
24export declare function keepUnstableUntilFirst<T>(obs$: Observable<T>): Observable<T>;
25/**
26 * Operator to block the zone until the first value has been emitted or the observable
27 * has completed/errored. This is used to make sure that universal waits until the first
28 * value from firebase but doesn't block the zone forever since the firebase subscription
29 * is still alive.
30 */
31export declare function ɵkeepUnstableUntilFirstFactory(schedulers: ɵAngularFireSchedulers): <T>(obs$: Observable<T>) => Observable<T>;
32export declare const ɵzoneWrap: <T = unknown>(it: T, blockUntilFirst: boolean) => T;