[sampo]

In this case, the API provides .pipe, with which you can then use whatever functions you want.