Tee pipe

Tees a readablestream, piping the left branch into the right-hand side stream, and returning the right branch for further use.

lhs %T>% rhs

Arguments

lhs

stream to be teed

rhs

stream to be piped to

See also

Other pipes: streampipe

Examples

# create a stream that prints the data sent to it
# and also increments each chunk by one
stream <- as_reader(1:100) %T>%
    walk_stream(function(data) print(data)) %|>%
    map_stream(function(data) data + 1)