2 instantiations of QuicStream
System.Net.Quic (2)
System\Net\Quic\QuicConnection.cs (2)
527stream = new QuicStream(_handle, type, _defaultStreamErrorCode); 703QuicStream stream = new QuicStream(_handle, data.Stream, data.Flags, _defaultStreamErrorCode);
76 references to QuicStream
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (5)
Internal\QuicConnectionContext.cs (2)
97var stream = await _connection.AcceptInboundStreamAsync(cancellationToken); 212QuicStream quicStream;
Internal\QuicStreamContext.cs (3)
23private QuicStream? _stream; 79public void Initialize(QuicStream stream) 483var stream = _stream;
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (26)
QuicConnectionContextTests.cs (12)
102await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 161await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional); 203await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 256await using var clientStream = await acceptTask.DefaultTimeout(); 328await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 371await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 416await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 465await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 605await using var clientStream = await requestState.QuicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 677await using var clientStream1 = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 705await using var clientStream2 = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 755await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
QuicConnectionListenerTests.cs (1)
129await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
QuicStreamContextTests.cs (12)
67await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 116await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 184await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 263await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 307await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional); 341await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional); 380await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional); 416await using var clientStream = await quicConnection.AcceptInboundStreamAsync(); 457await using var clientStream = await quicConnection.AcceptInboundStreamAsync(); 496await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 546await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 573await using var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
QuicTestHelpers.cs (1)
146var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
System.Net.Http (12)
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (10)
29private readonly Dictionary<QuicStream, Http3RequestStream> _activeRequests = new Dictionary<QuicStream, Http3RequestStream>(); 35private QuicStream? _clientControl; 267QuicStream? quicStream = null; 436foreach (KeyValuePair<QuicStream, Http3RequestStream> request in _activeRequests) 454public void RemoveStream(QuicStream stream) 539ValueTask<QuicStream> streamTask; 552QuicStream stream = await streamTask.ConfigureAwait(false); 578private async Task ProcessServerStreamAsync(QuicStream stream) 717private async Task ProcessServerControlStreamAsync(QuicStream stream, ArrayBuffer buffer)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (2)
28private readonly QuicStream _stream; 70public Http3RequestStream(HttpRequestMessage request, Http3Connection connection, QuicStream stream)
System.Net.Quic (33)
System\Net\Quic\QuicAbortDirection.cs (2)
7/// Specifies direction of the <see cref="QuicStream"/> which is to be <see cref="QuicStream.Abort(QuicAbortDirection, long)">aborted</see>.
System\Net\Quic\QuicConnection.cs (14)
32/// <see cref="QuicConnection" /> itself doesn't send or receive data but rather allows opening and/or accepting multiple <see cref="QuicStream" />. 149private readonly Channel<QuicStream> _acceptQueue = Channel.CreateUnbounded<QuicStream>(new UnboundedChannelOptions() 171/// From <see cref="QuicConnectionOptions.DefaultStreamErrorCode"/>, passed to newly created <see cref="QuicStream"/>. 487/// For that purpose we pass this function to <see cref="QuicStream"/> so that it can call it from <c>START_COMPLETE</c> event handler. 513/// Create an outbound uni/bidirectional <see cref="QuicStream" />. 519/// <returns>An asynchronous task that completes with the opened <see cref="QuicStream" />.</returns> 520public async ValueTask<QuicStream> OpenOutboundStreamAsync(QuicStreamType type, CancellationToken cancellationToken = default) 524QuicStream? stream = null; 558/// Accepts an inbound <see cref="QuicStream" />. 561/// <returns>An asynchronous task that completes with the accepted <see cref="QuicStream" />.</returns> 562public async ValueTask<QuicStream> AcceptInboundStreamAsync(CancellationToken cancellationToken = default) 703QuicStream stream = new QuicStream(_handle, data.Stream, data.Flags, _defaultStreamErrorCode); 863while (_acceptQueue.Reader.TryRead(out QuicStream? stream))
System\Net\Quic\QuicConnectionOptions.cs (1)
12/// Collection of receive window sizes for <see cref="QuicConnection"/> as a whole and for individual <see cref="QuicStream"/> types.
System\Net\Quic\QuicError.cs (1)
7/// Defines the various error conditions for <see cref="QuicListener"/>, <see cref="QuicConnection"/> and <see cref="QuicStream"/> operations.
System\Net\Quic\QuicStream.cs (11)
26/// <see cref="QuicStream" /> can be <see cref="QuicStreamType.Unidirectional">unidirectional</see>, i.e.: write-only for the opening side, 30/// <see cref="QuicStream"/> can be used in a same way as any other <see cref="Stream"/>. 31/// Apart from stream API, <see cref="QuicStream"/> also exposes QUIC specific features: 76if (target is QuicStream stream) 99if (target is QuicStream stream) 125/// Provided via <see cref="StartAsync(Action{QuicStreamType}, CancellationToken)" /> from <see cref="QuicConnection" /> so that <see cref="QuicStream"/> can decrement its available stream count field. 161/// Initializes a new instance of an outbound <see cref="QuicStream" />. 202/// Initializes a new instance of an inbound <see cref="QuicStream" />. 250/// <returns>An asynchronous task that completes with the opened <see cref="QuicStream" />.</returns> 364return ValueTask.FromException(ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(nameof(QuicStream)))); 678if (!stateHandle.IsAllocated || stateHandle.Target is not QuicStream instance)
System\Net\Quic\QuicStream.Stream.cs (4)
17/// <summary>Gets a value indicating whether the <see cref="QuicStream" /> supports seeking.</summary> 42/// <summary>Gets a value that indicates whether the <see cref="QuicStream" /> can timeout.</summary> 88/// <summary>Gets a value indicating whether the <see cref="QuicStream" /> supports reading.</summary> 151/// <summary>Gets a value indicating whether the <see cref="QuicStream" /> supports writing.</summary>