1 | import { AsyncMapper, _passNothingPredicate, Mapper } from '@naturalcycles/js-lib'
|
2 | import { transformMap, TransformMapOptions, transformMapSync } from '../..'
|
3 | import { WritableTyped } from '../stream.model'
|
4 |
|
5 |
|
6 |
|
7 |
|
8 | export function writableForEach<IN = any>(
|
9 | mapper: AsyncMapper<IN, void>,
|
10 | opt: TransformMapOptions<IN, void> = {},
|
11 | ): WritableTyped<IN> {
|
12 | return transformMap<IN, void>(mapper, { ...opt, predicate: _passNothingPredicate })
|
13 | }
|
14 |
|
15 |
|
16 |
|
17 |
|
18 | export function writableForEachSync<IN = any>(
|
19 | mapper: Mapper<IN, void>,
|
20 | opt: TransformMapOptions<IN, void> = {},
|
21 | ): WritableTyped<IN> {
|
22 | return transformMapSync<IN, void>(mapper, { ...opt, predicate: _passNothingPredicate })
|
23 | }
|