Stream.fromPromise closing stream after promise is fulfilled or rejected