Haskell library providing a continuation-based stream processor arrow