1 instantiation of Http3RequestStream
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (1)
286requestStream = new Http3RequestStream(request, this, quicStream);
19 references to Http3RequestStream
System.Net.Http (19)
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (6)
29private readonly Dictionary<QuicStream, Http3RequestStream> _activeRequests = new Dictionary<QuicStream, Http3RequestStream>(); 268Http3RequestStream? requestStream = null; 418var streamsToGoAway = new List<Http3RequestStream>(); 436foreach (KeyValuePair<QuicStream, Http3RequestStream> request in _activeRequests) 448foreach (Http3RequestStream stream in streamsToGoAway)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (13)
460timer = new Timer(static o => ((Http3RequestStream)o!)._expect100ContinueCompletionSource!.TrySetResult(true), 1155Debug.Fail($"Unexpected {nameof(Http3RequestStream)}.{nameof(_headerState)} '{_headerState}'."); 1445private Http3RequestStream? _stream; 1452public Http3ReadStream(Http3RequestStream stream) 1465Http3RequestStream? stream = Interlocked.Exchange(ref _stream, null); 1492Http3RequestStream? stream = Interlocked.Exchange(ref _stream, null); 1507Http3RequestStream? stream = _stream; 1516Http3RequestStream? stream = _stream; 1520return ValueTask.FromException<int>(ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(nameof(Http3RequestStream)))); 1536private Http3RequestStream? _stream; 1544public Http3WriteStream(Http3RequestStream stream) 1569Http3RequestStream? stream = _stream; 1581Http3RequestStream? stream = _stream;