328_writePos = _readPos = _readLen = 0; 446_writePos = 0; 460_writePos = 0; 836_writePos += bytesToWrite; 957_writePos = 0; 978_writePos = 0; 983_writePos = 0; 1194_writePos = 0; 1221_writePos = 0; 1232_writePos = 0; 1267_buffer[_writePos++] = value;

183Buffer.InternalBlockCopy(_buffer, 0, shadowBuffer, 0, _writePos); 234if (_writePos > 0) 247Contract.Assert(! (_writePos > 0 && _readPos != _readLen), "Read and Write buffers cannot both have data in them at the same time."); 248return _stream.Position + (_readPos - _readLen + _writePos); 258if (_writePos > 0) 296if (_writePos > 0) { 299Contract.Assert(_writePos == 0 && _readPos == 0 && _readLen == 0); 320Contract.Assert(_writePos == 0 && _readPos == 0 && _readLen == 0); 339return FlushAsyncInternal(cancellationToken, this, _stream, _writePos, _readPos, _readLen); 359Contract.Assert(_this._writePos == 0 && _this._readPos == 0 && _this._readLen == 0); 379Contract.Assert(_this._writePos == 0 && _this._readPos == 0 && _this._readLen == 0); 388Contract.Assert(_this._writePos == 0 && _this._readPos == _this._readLen); 402Contract.Assert(_writePos == 0, "BufferedStream: Write buffer must be empty in FlushRead!"); 442Contract.Assert(_buffer != null && _bufferSize >= _writePos, 445_stream.Write(_buffer, 0, _writePos); 456Contract.Assert(_buffer != null && _bufferSize >= _writePos, 459await _stream.WriteAsync(_buffer, 0, _writePos, cancellationToken).ConfigureAwait(false); 539if (_writePos > 0) 767if (_writePos > 0) 810if (_writePos > 0) 828Int32 bytesToWrite = Math.Min(_bufferSize - _writePos, count); 834Buffer.InternalBlockCopy(array, offset, _buffer, _writePos, bytesToWrite); 870if (_writePos == 0) 933Contract.Assert(_writePos < _bufferSize); 938totalUserBytes = _writePos + count; 946if (_writePos < _bufferSize) { 953Contract.Assert(_writePos == _bufferSize); 956_stream.Write(_buffer, 0, _writePos); 962Contract.Assert(_writePos < _bufferSize); 967if (_writePos > 0) { 976Buffer.InternalBlockCopy(array, offset, _buffer, _writePos, count); 982_stream.Write(_buffer, 0, _writePos); 1021if (_writePos == 0) 1025Contract.Assert(_writePos < _bufferSize); 1026completeSynchronously = (count < _bufferSize - _writePos); 1106if (_writePos == 0) 1109Contract.Assert(_writePos < _bufferSize); 1112completeSynchronously = (count < _bufferSize - _writePos); 1163if (_writePos == 0) 1169totalUserBytes = _writePos + count; 1177if (_writePos < _bufferSize) { 1184Contract.Assert(_writePos == _bufferSize); 1189_stream.BeginWrite(_buffer, 0, _writePos, BeginEndAwaitableAdapter.Callback, _beginEndAwaitable); 1192await _stream.WriteAsync(_buffer, 0, _writePos, cancellationToken).ConfigureAwait(false); 1199Contract.Assert(_writePos < _bufferSize); 1204if (_writePos > 0) { 1213Buffer.InternalBlockCopy(array, offset, _buffer, _writePos, count); 1227_stream.BeginWrite(_buffer, 0, _writePos, BeginEndAwaitableAdapter.Callback, _beginEndAwaitable); 1230await _stream.WriteAsync(_buffer, 0, _writePos, cancellationToken).ConfigureAwait(false); 1256if (_writePos == 0) { 1264if (_writePos >= _bufferSize - 1) 1269Contract.Assert(_writePos < _bufferSize); 1279if (_writePos > 0) {