(req, err, cb)
| 152 | } |
| 153 | |
| 154 | function afterWriteDispatched(req, err, cb) { |
| 155 | req.bytes = streamBaseState[kBytesWritten]; |
| 156 | req.async = !!streamBaseState[kLastWriteWasAsync]; |
| 157 | |
| 158 | if (err !== 0) |
| 159 | return cb(new ErrnoException(err, 'write', req.error)); |
| 160 | |
| 161 | if (!req.async && typeof req.callback === 'function') { |
| 162 | req.callback(); |
| 163 | } |
| 164 | } |
| 165 | |
| 166 | function onStreamRead(arrayBuffer) { |
| 167 | const nread = streamBaseState[kReadBytesOrError]; |
no test coverage detected