3 instantiations of WebTransportStream
InMemory.FunctionalTests (1)
Http3\WebTransport\WebTransportTestUtilities.cs (1)
87
return new
WebTransportStream
(TestContextFactory.CreateHttp3StreamContext("id", null, new TestServiceContext(), features, null, null, null, transport), type);
Microsoft.AspNetCore.Server.Kestrel.Core (2)
Internal\Http3\Http3Connection.cs (1)
639
var webtransportStream = new
WebTransportStream
(stream.Context, type);
Internal\WebTransport\WebTransportSession.cs (1)
133
var stream = new
WebTransportStream
(streamContext, WebTransportStreamType.Output);
11 references to WebTransportStream
InMemory.FunctionalTests (4)
Http3\WebTransport\WebTransportSessionTests.cs (1)
97
var
_ = WebTransportTestUtilities.CreateStream(WebTransportStreamType.Bidirectional);
Http3\WebTransport\WebTransportStreamTests.cs (2)
21
var
stream = WebTransportTestUtilities.CreateStream(type, memory);
39
var
stream = WebTransportTestUtilities.CreateStream(WebTransportStreamType.Bidirectional, memory);
Http3\WebTransport\WebTransportTestUtilities.cs (1)
75
public static
WebTransportStream
CreateStream(WebTransportStreamType type, Memory<byte>? memory = null)
Microsoft.AspNetCore.Server.Kestrel.Core (7)
Internal\Http3\Http3Connection.cs (1)
639
var
webtransportStream = new WebTransportStream(stream.Context, type);
Internal\WebTransport\WebTransportSession.cs (6)
24
private readonly ConcurrentDictionary<long,
WebTransportStream
> _openStreams = new();
26
private readonly Channel<
WebTransportStream
> _pendingStreams;
52
_pendingStreams = Channel.CreateUnbounded<
WebTransportStream
>();
133
var
stream = new WebTransportStream(streamContext, WebTransportStreamType.Output);
145
internal void AddStream(
WebTransportStream
stream)
185
var success = _openStreams.Remove(streamId, out
var
stream);