Async streams as a stream wrapper with test.