sync stream works great
moved repipe to its own module