HTTP implementation on async streams