/**
 * Service for consuming investigation progress streams
 * Runs in background and updates the progress store
 */
import { HttpClient } from '../utils/http-client.js';
import { AuthenticationService } from './auth.service.js';
export declare class InvestigationStreamService {
    private httpClient;
    private authService;
    private activeStreams;
    constructor(httpClient: HttpClient, authService: AuthenticationService);
    /**
     * Start streaming progress updates for a session
     * Returns immediately while stream runs in background
     */
    startStreaming(sessionUuid: string, promptCycleId: string, projectUuid: string): Promise<void>;
    /**
     * Stop streaming for a session
     */
    stopStreaming(sessionUuid: string): void;
    /**
     * Consume the SSE stream and update progress store
     */
    private consumeStream;
    /**
     * Process a single stream event
     */
    private processStreamEvent;
    /**
     * Humanize category names
     */
    private humanizeCategory;
    /**
     * Check if actively streaming
     */
    isStreaming(sessionUuid: string): boolean;
    /**
     * Get active stream count (for debugging)
     */
    getActiveStreamCount(): number;
    /**
     * Stop all streams (cleanup on shutdown)
     */
    stopAll(): void;
}