(stream, bytes)
| 1945 | } |
| 1946 | |
| 1947 | function trackWriteState(stream, bytes) { |
| 1948 | const session = stream[kSession]; |
| 1949 | stream[kState].writeQueueSize += bytes; |
| 1950 | session[kState].writeQueueSize += bytes; |
| 1951 | session[kHandle].chunksSentSinceLastWrite = 0; |
| 1952 | } |
| 1953 | |
| 1954 | function streamOnResume() { |
| 1955 | if (!this.destroyed) |
no outgoing calls
no test coverage detected
searching dependent graphs…