1 | import { NgZone } from '@angular/core';
|
2 | import { Observable, SchedulerAction, SchedulerLike, Subscription } from 'rxjs';
|
3 | import * as i0 from "@angular/core";
|
4 |
|
5 |
|
6 |
|
7 | export 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 | }
|
14 | export 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 | }
|
22 | export declare function observeOutsideAngular<T>(obs$: Observable<T>): Observable<T>;
|
23 | export declare function observeInsideAngular<T>(obs$: Observable<T>): Observable<T>;
|
24 | export 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 | */
|
31 | export declare function ɵkeepUnstableUntilFirstFactory(schedulers: ɵAngularFireSchedulers): <T>(obs$: Observable<T>) => Observable<T>;
|
32 | export declare const ɵzoneWrap: <T = unknown>(it: T, blockUntilFirst: boolean) => T;
|