fix(pipe): avoid entering blocking region in tokio async tasks

fix(pipe): avoid entering blocking region in tokio async tasks #19