/** * @internal */ export declare const read: unique symbol; /** * a pipe source should be able to write its output to a pipe target * * @public */ export interface PipeSource { pipe: (target: PipeTarget) => void; unpipe: () => void; } /** * a pipe target can receive data from a pipe source * * @public */ export interface PipeTarget> { [read]: (value: T, source?: S) => void; } /** * @public */ export interface Pipe extends PipeTarget, PipeSource { } /** * @public */ export declare class Transform implements PipeTarget>, PipeSource { handler: (value: TIn, source?: PipeSource) => TOut; private target; /** * creates a pipe that transforms data from `TIn` to `TOut` * @param handler - transform data in pipe */ constructor(handler: (value: TIn) => TOut); pipe(target: PipeTarget): void; unpipe(): void; /** * @internal */ [read](value: TIn, source?: PipeSource): void; } /** * @public */ declare const to: { (fn: (v: T, s?: PipeSource) => any): PipeTarget; console(level?: ConsoleLevel): { [read]: ((message?: any, ...optionalParams: any[]) => void) | ((message?: any, ...optionalParams: any[]) => void) | ((message?: any, ...optionalParams: any[]) => void) | ((message?: any, ...optionalParams: any[]) => void); }; }; /** * @public */ export type ConsoleLevel = 'debug' | 'log' | 'warn' | 'error'; export { to }; //# sourceMappingURL=pipeable.d.ts.map