Stream.distinct test
Test Stream.fromPromise and update error handling