(state)
| 868 | }; |
| 869 | |
| 870 | function needFinish(state) { |
| 871 | return ( |
| 872 | // State is ended && constructed but not destroyed, finished, writing, errorEmitted or closedEmitted |
| 873 | (state[kState] & ( |
| 874 | kEnding | |
| 875 | kDestroyed | |
| 876 | kConstructed | |
| 877 | kFinished | |
| 878 | kWriting | |
| 879 | kErrorEmitted | |
| 880 | kCloseEmitted | |
| 881 | kErrored | |
| 882 | kBuffered |
| 883 | )) === (kEnding | kConstructed) && state.length === 0); |
| 884 | } |
| 885 | |
| 886 | function onFinish(stream, state, err) { |
| 887 | if ((state[kState] & kPrefinished) !== 0) { |
no outgoing calls
no test coverage detected
searching dependent graphs…