(isError, error)
| 949 | } |
| 950 | |
| 951 | function shutdown(isError, error) { |
| 952 | if (shuttingDown === true) { |
| 953 | return; |
| 954 | } |
| 955 | shuttingDown = true; |
| 956 | |
| 957 | if (dest.state === 'writable' && WritableStreamCloseQueuedOrInFlight(dest) === false) { |
| 958 | waitForWritesToFinish().then(() => finalize(isError, error)); |
| 959 | } |
| 960 | else { |
| 961 | finalize(isError, error); |
| 962 | } |
| 963 | } |
| 964 | function finalize(isError, error) { |
| 965 | WritableStreamDefaultWriterRelease(writer); |
| 966 | ReadableStreamDefaultReaderRelease(reader); |
no test coverage detected