| 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>;
|