import { Observable } from 'rxjs';
import type { OperatorFunction, ObservedValueOf } from 'rxjs';
import type { ActionError } from '../store/state/actions/action-creators';
/**
 * this function is a wrapper around catchError
 * --> helps to log the error and returns error action object
 *
 * @param msg message for the error.
 * @param context context for the error
 * @returns the error action object.
 */
export declare const logAndCatchError: (msg: string, context?: string, actionMgrID?: string) => OperatorFunction<any, any | ObservedValueOf<Observable<ActionError>>>;
interface RequestPayload {
    signal: {
        cancel: (reason: string) => void;
    };
    [key: string]: unknown;
}
type ComparatorFn = (a: unknown, b: unknown) => boolean;
/**
 * this function is a wrapper around takeUntil
 * --> helps to cancel the original request if CANCEL_ACTION was triggered
 *
 * @param action$ observable stream
 * @param reqPayload request Payload
 * @param comparator function to compare properties between cancel request and normal request payload
 * @returns outer observable
 */
export declare const continueRequestUntil: (action$: Observable<{
    type: string;
    id: string;
}>, reqPayload: RequestPayload, comparator: ComparatorFn) => import("rxjs").MonoTypeOperatorFunction<unknown>;
/**
 * --> helps to throttle based on time and distinct payload
 *
 * @param delay number of milliseconds for debounce
 * @param comparator function to compare properties between prev request and next request payload
 * @returns 1) empty observable within delay time. OR
 *          2) actual value if delay time crosses.
 */
export declare const throttleUntilChanged: <T>(delay: number, comparator?: ComparatorFn) => ((source: Observable<T>) => Observable<T>);
export {};