ztellman/manifold doesn't give you much wrt error propagation on streams... we have versions of stream/map, stream/reduce etc which catch exceptions and either wrap them in marker records (e.g map) or propagate errors from marker records (e.g. reduce) as an errored promise (a deferred in manifold parlance)