import { HttpClient } from '@angular/common/http';
import { Observable } from 'rxjs';
import { SseOptions } from './sse-options.interface';
export declare class SseClientSubscriber {
    private httpClient;
    private sseOptions;
    private httpClientOptions;
    private url;
    private method;
    private static readonly SEPARATOR;
    private progress;
    private chunk;
    constructor(httpClient: HttpClient, sseOptions: SseOptions, httpClientOptions: any, url: string, method: string);
    createObservable(): Observable<string | Event>;
    private subscribeStreamRequest;
    private repeatWhen;
    private retryWhen;
    private threatRequestError;
    private isValidStatus;
    private parseStreamEvent;
    private onStreamProgress;
    private onStreamCompleted;
    private parseEventData;
    private parseEventChunk;
    private parseChunkLine;
    private dispatchStreamData;
    private validEvent;
    private messageEvent;
    private errorEvent;
}