2 instantiations of QuicStream
System.Net.Quic (2)
System\Net\Quic\QuicConnection.cs (2)
423stream = new QuicStream(_handle, type, _defaultStreamErrorCode); 585QuicStream stream = new QuicStream(_handle, data.Stream, data.Flags, _defaultStreamErrorCode);
73 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(); 328var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 371var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 416var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 465var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 596var clientStream = await requestState.QuicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 646var clientStream1 = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 674var clientStream2 = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 724var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
QuicConnectionListenerTests.cs (1)
129using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
QuicStreamContextTests.cs (12)
67var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 116var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 184var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 262await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 306await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional); 340await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional); 379await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional); 415await using var clientStream = await quicConnection.AcceptInboundStreamAsync(); 456await using var clientStream = await quicConnection.AcceptInboundStreamAsync(); 495await using var clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 545var clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional); 572var 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; 168QuicStream? quicStream = null; 329foreach (KeyValuePair<QuicStream, Http3RequestStream> request in _activeRequests) 347public void RemoveStream(QuicStream stream) 434ValueTask<QuicStream> streamTask; 447QuicStream stream = await streamTask.ConfigureAwait(false); 473private async Task ProcessServerStreamAsync(QuicStream stream) 612private async Task ProcessServerControlStreamAsync(QuicStream stream, ArrayBuffer buffer)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (2)
28private readonly QuicStream _stream; 68public Http3RequestStream(HttpRequestMessage request, Http3Connection connection, QuicStream stream)
System.Net.Quic (30)
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 (13)
29/// <see cref="QuicConnection" /> itself doesn't send or receive data but rather allows opening and/or accepting multiple <see cref="QuicStream" />. 143private readonly Channel<QuicStream> _acceptQueue = Channel.CreateUnbounded<QuicStream>(new UnboundedChannelOptions() 165/// From <see cref="QuicConnectionOptions.DefaultStreamErrorCode"/>, passed to newly created <see cref="QuicStream"/>. 409/// Create an outbound uni/bidirectional <see cref="QuicStream" />. 415/// <returns>An asynchronous task that completes with the opened <see cref="QuicStream" />.</returns> 416public async ValueTask<QuicStream> OpenOutboundStreamAsync(QuicStreamType type, CancellationToken cancellationToken = default) 420QuicStream? stream = null; 458/// Accepts an inbound <see cref="QuicStream" />. 461/// <returns>An asynchronous task that completes with the accepted <see cref="QuicStream" />.</returns> 462public async ValueTask<QuicStream> AcceptInboundStreamAsync(CancellationToken cancellationToken = default) 585QuicStream stream = new QuicStream(_handle, data.Stream, data.Flags, _defaultStreamErrorCode); 732while (_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 (9)
25/// <see cref="QuicStream" /> can be <see cref="QuicStreamType.Unidirectional">unidirectional</see>, i.e.: write-only for the opening side, 29/// <see cref="QuicStream"/> can be used in a same way as any other <see cref="Stream"/>. 30/// Apart from stream API, <see cref="QuicStream"/> also exposes QUIC specific features: 75if (target is QuicStream stream) 98if (target is QuicStream stream) 154/// Initializes a new instance of an outbound <see cref="QuicStream" />. 198/// Initializes a new instance of an inbound <see cref="QuicStream" />. 243/// <returns>An asynchronous task that completes with the opened <see cref="QuicStream" />.</returns> 664if (!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>