Add concurrent pipe processing