UNPKG

455 BTypeScriptView Raw
1import { AsyncMapper } from '@naturalcycles/js-lib';
2import { TransformOptions, TransformTyped } from '../stream.model';
3/**
4 * Similar to RxJS `tap` - allows to run a function for each stream item, without affecting the result.
5 * Item is passed through to the output.
6 *
7 * Can also act as a counter, since `index` is passed to `fn`
8 */
9export declare function transformTap<IN>(fn: AsyncMapper<IN, any>, opt?: TransformOptions): TransformTyped<IN, IN>;