(stream, promise, action)
| 920 | } |
| 921 | |
| 922 | function isOrBecomesClosed(stream, promise, action) { |
| 923 | if (stream.state === 'closed') { |
| 924 | action(); |
| 925 | } else { |
| 926 | promise.then(action).catch(ignoreReason); |
| 927 | } |
| 928 | } |
| 929 | |
| 930 | function shutdownWithAction(action, originalIsError, originalError) { |
| 931 | if (shuttingDown === true) { |
no outgoing calls
no test coverage detected