unit test for async pipes