import { Observable } from "rxjs";
export interface ProcessRequestPayload<T> {
    readonly request$: Promise<T> | Observable<T>;
    readonly publishResult: (payload?: any) => void;
    readonly publishError: (payload?: any) => void;
}
/**
 * Observes a promise or observable based
 * request
 *
 * Allows intercepting value and error events
 * with a custom observer
 */
export declare function processRequest$<T>(payload: ProcessRequestPayload<T>): Promise<T>;