/// import { Observable } from "rxjs"; import { Writable } from "stream"; export declare function interceptWritable(writable: Writable): Observable; export declare type WritableMapper = (chunk: Buffer) => Buffer; export declare function mapWritable(writable: Writable, chunked?: boolean): Observable;