import { TT$ } from '@upradata/util'; import { Stream, WritableStream } from '../types'; export declare type ConcatGeneratorFunction = (source: Stream) => TT$; export declare type ConcatStreamGenerator = TT$ | TT$ | ConcatStreamGenerators; export declare type ConcatStreamGenerators = TT$; export declare function isConcatGeneratorFunction(gen: any): gen is ConcatGeneratorFunction; export declare type PipeGeneratorFunction = () => TT$; export declare type PipeStreamGenerator = TT$ | TT$; export declare function isPipeGeneratorFunction(gen: any): gen is PipeGeneratorFunction;