import { OnDestroy } from '@angular/core';
import { Observable } from 'rxjs';
import * as i0 from "@angular/core";
/**
 * Extend this when need to handle subscriptions clean up or side-effects
 *
 * ```ts
 * @Component({
 *   selector: "app-color-text",
 *   template: `<span (click)="performMyAction('run')">{{ color }}</span>`,
 *   changeDetection: ChangeDetectionStrategy.OnPush,
 * })
 * class ColorTextComponent extends SubscribeSink {
 *   @Input() color: string;
 *
 *   color$ = this.getInput$("color");
 *
 *   constructor() {
 *     super();
 *
 *     const someOtherObservable$ = this.color$.pipe(...);
 *
 *     // no need to worry about unsubscribing. It'll be done automatically
 *     this.subscribeTo(someOtherObservable$);
 *   }
 *
 *   performMyAction = this.createEffect((action$) =>
 *     action$.pipe(
 *       switchMap((action) => api.post(action))
 *     )
 *   );
 * }
 */
export declare class SubscribeSink implements OnDestroy {
    private destroy$$;
    destroy$: Observable<boolean>;
    createEffect<T>(factoryFn: (source: Observable<T>) => Observable<unknown>): (value: T) => void;
    subscribeTo<T>(source: Observable<T>): void;
    ngOnDestroy(): void;
    static ɵfac: i0.ɵɵFactoryDeclaration<SubscribeSink, never>;
    static ɵprov: i0.ɵɵInjectableDeclaration<SubscribeSink>;
}
export declare function createEffectFn<T>(factoryFn: (source: Observable<T>) => Observable<unknown>): (destroyed$: Observable<boolean>) => (value: T) => void;