A library that implements functional streams with promises