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