src/stream/writable/writableForEach.ts
import { AsyncMapper, _passNothingPredicate, Mapper } from '@naturalcycles/js-lib'
import { transformMap, TransformMapOptions, transformMapSync } from '../..'
import { WritableTyped } from '../stream.model'
/**
* Just an alias to transformMap that declares OUT as void.
*/
export function writableForEach<IN = any>(
mapper: AsyncMapper<IN, void>,
opt: TransformMapOptions<IN, void> = {},
): WritableTyped<IN> {
return transformMap<IN, void>(mapper, { ...opt, predicate: _passNothingPredicate })
}
/**
* Just an alias to transformMap that declares OUT as void.
*/
export function writableForEachSync<IN = any>(
mapper: Mapper<IN, void>,
opt: TransformMapOptions<IN, void> = {},
): WritableTyped<IN> {
return transformMapSync<IN, void>(mapper, { ...opt, predicate: _passNothingPredicate })
}