functional_streams: Stream pipe pipe

In ElianHugh/emitters: NodeJS-inspired events and io streams.

Description

A pipe for stream piping

Apply function fn to each chunk of data

Filter a stream based on a boolean function, only passing data that results in a true condition

Reduce stream data into one chunk via the iterative application of function fn to an accumulator and each chunk

See also base::Reduce

Map stream, but for side-effects

todo

Usage

lhs %|>% rhs

map_stream(fn)

filter_stream(fn)

reduce_stream(fn, base_value = 0)

walk_stream(fn)

collect_stream()

batch_stream(size)

Arguments

fn	function applied to each chunk of stream that returns a boolean value

Details

Form of reduce stream where all data is appended to a list before being emitted.

ElianHugh/emitters documentation built on Feb. 6, 2022, 4:55 a.m.