Use async instead of highland