import type { Stream } from '../stream'; import type { Subscriber } from '../stream'; export declare class BaseTransformation { protected stream: Stream; private afterOperations; constructor(stream: Stream); createStream(): Stream; onUnique(): this; onInitialSkipped(): this; thenUnique(): this; thenReset(fallbackValue?: T): this; protected applyAfterOperations(stream: Stream): Stream; protected subscribe(subscriber: Subscriber): Stream; protected isCallback(source: any): source is T; }