52 references to QuicStreamType
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (3)
Internal\QuicConnectionContext.cs (3)
219quicStream = await _connection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional, cancellationToken); 223quicStream = await _connection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional, cancellationToken); 228quicStream = await _connection.OpenOutboundStreamAsync(QuicStreamType.Bidirectional, cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (24)
QuicConnectionContextTests.cs (12)
69() => clientConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional).AsTask(), 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); 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 (10)
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); 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 (2)
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (2)
284quicStream = await conn.OpenOutboundStreamAsync(QuicStreamType.Bidirectional, cancellationToken).ConfigureAwait(false); 488_clientControl = await _connection!.OpenOutboundStreamAsync(QuicStreamType.Unidirectional).ConfigureAwait(false);
System.Net.Quic (23)
System\Net\Quic\QuicConnection.cs (11)
38/// Each connection can then open outbound stream: <see cref="QuicConnection.OpenOutboundStreamAsync(QuicStreamType, CancellationToken)" />, 192/// Optimization to avoid `Action` instantiation with every <see cref="OpenOutboundStreamAsync(QuicStreamType, CancellationToken)"/>. 193/// Holds <see cref="DecrementStreamCapacity(QuicStreamType)"/> method. 195private Action<QuicStreamType> _decrementStreamCapacity; 492private void DecrementStreamCapacity(QuicStreamType streamType) 494if (streamType == QuicStreamType.Unidirectional) 502if (streamType == QuicStreamType.Bidirectional) 520public async ValueTask<QuicStream> OpenOutboundStreamAsync(QuicStreamType type, CancellationToken cancellationToken = default) 707QuicStreamType type = data.Flags.HasFlag(QUIC_STREAM_OPEN_FLAGS.UNIDIRECTIONAL) ? QuicStreamType.Unidirectional : QuicStreamType.Bidirectional;
System\Net\Quic\QuicStream.cs (12)
26/// <see cref="QuicStream" /> can be <see cref="QuicStreamType.Unidirectional">unidirectional</see>, i.e.: write-only for the opening side, 27/// or <see cref="QuicStreamType.Bidirectional">bidirectional</see> which allows both side to write. 122private readonly QuicStreamType _type; 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. 128private Action<QuicStreamType>? _decrementStreamCapacity; 138public QuicStreamType Type => _type; 166internal unsafe QuicStream(MsQuicContextSafeHandle connectionHandle, QuicStreamType type, long defaultErrorCode) 174type == QuicStreamType.Unidirectional ? QUIC_STREAM_OPEN_FLAGS.UNIDIRECTIONAL : QUIC_STREAM_OPEN_FLAGS.NONE, 192_canRead = type == QuicStreamType.Bidirectional; 238_type = flags.HasFlag(QUIC_STREAM_OPEN_FLAGS.UNIDIRECTIONAL) ? QuicStreamType.Unidirectional : QuicStreamType.Bidirectional; 251internal ValueTask StartAsync(Action<QuicStreamType> decrementStreamCapacity, CancellationToken cancellationToken = default)