Lines Matching refs:self
185 const self = this[owner_symbol];
192 self.destroy(error);
193 self[kError] = error;
435 function processChunkSync(self, chunk, flushFlag) {
437 let availOutBefore = self._chunkSize - self._outOffset;
445 const state = self._writeState;
446 const handle = self._handle;
447 let buffer = self._outBuffer;
448 let offset = self._outOffset;
449 const chunkSize = self._chunkSize;
452 self.on('error', function onError(er) {
466 else if (self[kError])
467 throw self[kError];
485 if (nread > self._maxOutputLength) {
486 _close(self);
487 throw new ERR_BUFFER_TOO_LARGE(self._maxOutputLength);
513 self.bytesWritten = inputRead;
514 _close(self);
522 function processChunk(self, chunk, flushFlag, cb) {
523 const handle = self._handle;
528 handle.availOutBefore = self._chunkSize - self._outOffset;
537 self._outBuffer, // out
538 self._outOffset, // out_off
547 const self = this[owner_symbol];
548 const state = self._writeState;
550 if (self.destroyed) {
560 self.bytesWritten += inDelta;
565 const out = self._outBuffer.slice(self._outOffset, self._outOffset + have);
566 self._outOffset += have;
567 streamBufferIsFull = !self.push(out);
572 if (self.destroyed) {
578 if (availOutAfter === 0 || self._outOffset >= self._chunkSize) {
579 handle.availOutBefore = self._chunkSize;
580 self._outOffset = 0;
581 self._outBuffer = Buffer.allocUnsafe(self._chunkSize);
598 self._outBuffer, // out
599 self._outOffset, // out_off
600 self._chunkSize); // out_len
602 const oldRead = self._read;
603 self._read = (n) => {
604 self._read = oldRead;
609 self._outBuffer, // out
610 self._outOffset, // out_off
611 self._chunkSize); // out_len
612 self._read(n);
625 self.push(null);