import WebSocket from 'ws';
import { Observable } from 'rxjs';
import { Logger } from '../logging';
export declare function logWarningIfOutgoingStreamNotComplete(logger: Logger, data: Observable<WebSocket.Data>, outgoing: Observable<unknown>, timeout: number, id: string, name: string): Observable<never>;