Filter stream

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

filter_stream(fn, ...)

Arguments

fn

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

...

arguments passed to TransformStream

See also

Other functionals: batch_stream(), collect_stream(), flatten_stream(), limit_stream(), map_stream(), reduce_stream(), walk_stream()

Examples

filterer <- as_reader(1:10) %|>%
    filter_stream(~ .x < 5L) |>
    on("data", print)