import { AsyncMapper, CommonLogger } from '@naturalcycles/js-lib'; import { TransformOptions, TransformTyped } from '../stream.model'; export interface TransformTapOptions extends TransformOptions { logger?: CommonLogger; } /** * Similar to RxJS `tap` - allows to run a function for each stream item, without affecting the result. * Item is passed through to the output. * * Can also act as a counter, since `index` is passed to `fn` */ export declare function transformTap(fn: AsyncMapper, opt?: TransformTapOptions): TransformTyped;