A stream wrapper around reactphp for async streams