import { Observable } from 'rxjs/Observable';
import { SDKFetch, SDKFetchOptions } from './SDKFetch';
interface PollingOptions {
    /**
     * 最大轮询数
     */
    maxTimes?: number;
    /**
     * 轮询间隔
     */
    interval?: number;
    /**
     * 最大轮询间隔
     */
    maxInterval?: number;
    /**
     * 轮询间隔步长
     */
    intervalSteps?: number;
}
export interface AsyncJobOptions<T> extends AsyncJobCallbacks<T> {
    timeoutSeconds?: number;
    readySid?: string;
    pollingOptions?: PollingOptions;
}
interface AsyncJobCallbacks<T> {
    onPending?: () => void;
    onFulfilled?: (res: T) => void;
    onRejected?: (e: Error) => void;
}
declare type Options<T> = SDKFetchOptions & AsyncJobOptions<T>;
export declare class SDKAsyncJob {
    private fetch;
    constructor(fetch: SDKFetch);
    get<T>(path: string, query?: Object, options?: Options<T>): Observable<T>;
    post<T>(path: string, body?: any, options?: Options<T>): Observable<T>;
    put<T>(path: string, body?: any, options?: Options<T>): Observable<T>;
    delete<T>(path: string, body?: any, options?: Options<T>): Observable<T>;
    private appendQueryToUrl;
    private handleRes;
    private waitingForJobDone;
    private polling;
    private getAsyncJobResult;
    /**
     * 判断资源是否需要异步等待
     */
    private isAsyncResult;
    private normalizeQuery;
}
export {};