/// <reference types="node" />
/// <reference types="node" />
import { ChildProcess } from 'child_process';
import { Interface } from 'readline';
import { Observable, Subject, Subscription } from 'rxjs';
import { LogDb, LogRecord } from './logdb';
export declare class LogStream<T extends LogStream.Source<K> = LogStream.Source<any>, K = T extends LogStream.Source<infer U> ? U : never> {
    buffer: string[];
    logdb: LogDb;
    source: T;
    logsObservable: Observable<LogRecord>;
    logsSubject: Subject<LogRecord>;
    constructor(source: T);
    static fromProcess(execPath: string, params?: string[]): LogStream<LogStream.Source.Process>;
    static fromObservable<T>(name: string, observable: Observable<T>): LogStream<LogStream.Source<T>, T>;
    dumpToFile(path: string): Observable<boolean>;
}
export declare namespace LogStream {
    type Source<T = any> = Source.ObservableSource<T> | Source.Process;
    namespace Source {
        interface ObservableSource<T> {
            sType: 'observable';
            name: string;
            observable: Observable<T>;
            subscription?: Subscription;
        }
        interface Process {
            sType: 'process';
            process: ChildProcess;
            running: boolean;
            stdoutInterface: Interface;
            stderrInterface: Interface;
        }
    }
}
//# sourceMappingURL=logstream.d.ts.map