(stream, promise, action)
| 912 | } |
| 913 | |
| 914 | function isOrBecomesErrored(stream, promise, action) { |
| 915 | if (stream.state === 'errored') { |
| 916 | action(stream.storedError); |
| 917 | } else { |
| 918 | promise.catch(action); |
| 919 | } |
| 920 | } |
| 921 | |
| 922 | function isOrBecomesClosed(stream, promise, action) { |
| 923 | if (stream.state === 'closed') { |
no outgoing calls
no test coverage detected