caf_forward/pipe_forward