1 write to _stream
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)
74_stream = stream;
31 references to _stream
System.Net.Http (31)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (31)
93if (_stream.WritesClosed.IsCompleted) 95_connection.LogExceptions(_stream.DisposeAsync().AsTask()); 99_stream.Dispose(); 109_connection.RemoveStream(_stream); 119if (_stream.WritesClosed.IsCompleted) 121_connection.LogExceptions(_stream.DisposeAsync().AsTask()); 125await _stream.DisposeAsync().ConfigureAwait(false); 133_connection.RemoveStream(_stream); 241_stream.WritesClosed is { IsCompletedSuccessfully: false } writesClosed) 350_stream.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.RequestCancelled); 371_stream.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.InternalError); 376_stream.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.InternalError); 511_stream.CompleteWrites(); 558await _stream.WriteAsync(_sendBuffer.ActiveMemory, cancellationToken).ConfigureAwait(false); 559await _stream.WriteAsync(buffer, cancellationToken).ConfigureAwait(false); 568await _stream.WriteAsync(buffer, cancellationToken).ConfigureAwait(false); 577await _stream.WriteAsync(_sendBuffer.ActiveMemory, cancellationToken).ConfigureAwait(false); 578await _stream.WriteAsync(buffer, cancellationToken).ConfigureAwait(false); 588return _stream.WriteAsync(toSend, endStream, cancellationToken); 640int bytesRead = await _stream.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false); 908bytesRead = await _stream.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false); 967int bytesRead = await _stream.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false); 1038_stream.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.ExcessiveLoad); 1173int bytesRead = await _stream.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false); 1238int bytesRead = _stream.Read(buffer.Slice(0, copyLen)); 1310int bytesRead = await _stream.ReadAsync(buffer.Slice(0, copyLen), cancellationToken).ConfigureAwait(false); 1376_stream.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.RequestCancelled); 1381_stream.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.InternalError); 1433_stream.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.RequestCancelled); 1438_stream.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.RequestCancelled); 1481stream._connection.RemoveStream(stream._stream);