Function map

packages/db-ivm/src/operators/map.ts:32–47

(f: (data: T) => O)

 * @param f - The function to apply to each element
 */
export function map<T, O>(f: (data: T) => O): PipedOperator<T, O> {
  return (stream: IStreamBuilder<T>): IStreamBuilder<O> => {
    const output = new StreamBuilder<O>(
      stream.graph,
      new DifferenceStreamWriter<O>(),
    )
    const operator = new MapOperator<T, O>(
      stream.graph.getNextOperatorId(),
      stream.connectReader(),
      output.writer,
      f,
    )
    stream.graph.addOperator(operator)
    return output
  }
}