2 instantiations of QuicStream
System.Net.Quic (2)
System\Net\Quic\QuicConnection.cs (2)
423
stream = new
QuicStream
(_handle, type, _defaultStreamErrorCode);
585
QuicStream stream = new
QuicStream
(_handle, data.Stream, data.Flags, _defaultStreamErrorCode);
73 references to QuicStream
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (5)
Internal\QuicConnectionContext.cs (2)
97
var
stream = await _connection.AcceptInboundStreamAsync(cancellationToken);
212
QuicStream
quicStream;
Internal\QuicStreamContext.cs (3)
23
private
QuicStream
? _stream;
79
public void Initialize(
QuicStream
stream)
483
var
stream = _stream;
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (26)
QuicConnectionContextTests.cs (12)
102
await using
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
161
await using
var
clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional);
203
await using
var
clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
256
await using
var
clientStream = await acceptTask.DefaultTimeout();
328
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
371
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
416
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
465
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
596
var
clientStream = await requestState.QuicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
646
var
clientStream1 = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
674
var
clientStream2 = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
724
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
QuicConnectionListenerTests.cs (1)
129
using
var
clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
QuicStreamContextTests.cs (12)
67
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
116
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
184
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
262
await using
var
clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
306
await using
var
clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional);
340
await using
var
clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional);
379
await using
var
clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional);
415
await using
var
clientStream = await quicConnection.AcceptInboundStreamAsync();
456
await using
var
clientStream = await quicConnection.AcceptInboundStreamAsync();
495
await using
var
clientStream = await quicConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
545
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
572
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
QuicTestHelpers.cs (1)
146
var
clientStream = await clientConnection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional);
System.Net.Http (12)
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (10)
29
private readonly Dictionary<
QuicStream
, Http3RequestStream> _activeRequests = new Dictionary<
QuicStream
, Http3RequestStream>();
35
private
QuicStream
? _clientControl;
168
QuicStream
? quicStream = null;
329
foreach (KeyValuePair<
QuicStream
, Http3RequestStream> request in _activeRequests)
347
public void RemoveStream(
QuicStream
stream)
434
ValueTask<
QuicStream
> streamTask;
447
QuicStream
stream = await streamTask.ConfigureAwait(false);
473
private async Task ProcessServerStreamAsync(
QuicStream
stream)
612
private async Task ProcessServerControlStreamAsync(
QuicStream
stream, ArrayBuffer buffer)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (2)
28
private readonly
QuicStream
_stream;
68
public 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
" />.
143
private 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>
416
public async ValueTask<
QuicStream
> OpenOutboundStreamAsync(QuicStreamType type, CancellationToken cancellationToken = default)
420
QuicStream
? stream = null;
458
/// Accepts an inbound <see cref="
QuicStream
" />.
461
/// <returns>An asynchronous task that completes with the accepted <see cref="
QuicStream
" />.</returns>
462
public async ValueTask<
QuicStream
> AcceptInboundStreamAsync(CancellationToken cancellationToken = default)
585
QuicStream
stream = new QuicStream(_handle, data.Stream, data.Flags, _defaultStreamErrorCode);
732
while (_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:
75
if (target is
QuicStream
stream)
98
if (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>
664
if (!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>