Async Pipeline implementation