1 type derived from NetworkStream
Microsoft.Diagnostics.NETCore.Client (1)
DiagnosticsIpc\ExposedSocketNetworkStream.cs (1)
9NetworkStream
60 instantiations of NetworkStream
aspire (4)
Backchannel\AppHostAuxiliaryBackchannel.cs (1)
186var stream = new NetworkStream(socket, ownsSocket: true);
Backchannel\AppHostCliBackchannel.cs (1)
337var stream = new NetworkStream(socket, true);
Backchannel\ExtensionBackchannel.cs (1)
267var stream = new SslStream(new NetworkStream(socket, true),
Projects\AppHostRpcClient.cs (1)
233return new NetworkStream(socket, ownsSocket: true);
aspire-managed (1)
TerminalHostForwarder.cs (1)
136using var stream = new NetworkStream(socket);
Aspire.Cli.Tests (7)
Backchannel\AppHostAuxiliaryBackchannelTests.cs (1)
141var serverStream = new NetworkStream(serverSocket, ownsSocket: true);
Backchannel\AppHostCliBackchannelTests.cs (1)
179var stream = new NetworkStream(socket, ownsSocket: true);
Backchannel\AppHostConnectionResolverTests.cs (1)
714var stream = new NetworkStream(serverSocket, ownsSocket: true);
Commands\PsCommandTests.cs (1)
860var serverStream = new NetworkStream(serverSocket, ownsSocket: true);
Projects\RunningInstanceManagerTests.cs (1)
91var serverStream = new NetworkStream(serverSocket, ownsSocket: true);
TestServices\TerminalTapeTestHost.cs (1)
67var client = await _presentation.AddClient(new NetworkStream(socket, ownsSocket: true), _stopping.Token);
TestServices\TestAuxiliaryBackchannelServer.cs (1)
29var stream = new NetworkStream(socket, ownsSocket: true);
Aspire.Hosting (4)
Backchannel\AuxiliaryBackchannelService.cs (1)
144using var stream = new NetworkStream(ownedClientSocket, ownsSocket: false);
Backchannel\BackchannelService.cs (1)
77var stream = new NetworkStream(clientSocket, true);
Backchannel\TerminalHostControlClient.cs (1)
66var stream = new NetworkStream(socket, ownsSocket: true);
Dcp\DcpHost.cs (1)
560using var stream = new NetworkStream(socket, ownsSocket: true);
Aspire.Hosting.CodeGeneration.Go.Tests (1)
AtsGoCodeGeneratorTests.cs (1)
271: new NetworkStream(await socket!.AcceptAsync(timeout.Token), ownsSocket: true);
Aspire.Hosting.Native.Client (1)
NativeClient.cs (1)
153client = new NativeClient(new NetworkStream(socket, ownsSocket: true), timeProvider);
Aspire.Hosting.Native.Core.Tests (4)
TestServices\NativeActivationRpcTestHost.cs (1)
32using var stream = new NetworkStream(socket, ownsSocket: false);
TestServices\NativeAuxiliaryTestHost.cs (1)
65var stream = new NetworkStream(socket, ownsSocket: true);
TestServices\NativeCliTestHost.cs (1)
38var stream = new NetworkStream(socket, ownsSocket: true);
TestServices\NativeSocketTestHost.cs (1)
85_stream = new NetworkStream(_socket, ownsSocket: true);
Aspire.Hosting.Native.Server (2)
Rpc\NativeRpcListener.cs (1)
166return new NetworkStream(await _listener.AcceptAsync(cancellationToken).ConfigureAwait(false), ownsSocket: true);
Transport\SocketConnectionListener.cs (1)
58using var stream = new NetworkStream(socket, ownsSocket: false);
Aspire.Hosting.RemoteHost (1)
JsonRpcServer.cs (1)
228var stream = new NetworkStream(clientSocket, ownsSocket: true);
Aspire.Hosting.RemoteHost.Tests (2)
JsonRpcAuthenticationTests.cs (1)
401return new NetworkStream(socket, ownsSocket: true);
TestServices\IntegrationHostProcessFixture.cs (1)
385stream = new NetworkStream(socket, ownsSocket: true);
Aspire.Hosting.Tests (15)
Backchannel\AppHostBackchannelTests.cs (2)
66using var stream = new NetworkStream(socket, true); 102using var stream = new NetworkStream(socket, true);
Backchannel\AuxiliaryBackchannelTests.cs (12)
136using var stream = new NetworkStream(socket, ownsSocket: false); 170using var stream = new NetworkStream(socket, ownsSocket: true); 205using var stream = new NetworkStream(socket, ownsSocket: true); 248using var stream = new NetworkStream(socket, ownsSocket: true); 290using var stream = new NetworkStream(socket, ownsSocket: true); 370using var stream = new NetworkStream(socket, ownsSocket: true); 411using var stream = new NetworkStream(socket, ownsSocket: true); 448using var stream = new NetworkStream(socket, ownsSocket: true); 498using var stream = new NetworkStream(socket, ownsSocket: true); 539using var stream = new NetworkStream(socket, ownsSocket: true); 582using var stream = new NetworkStream(socket, ownsSocket: true); 626using var stream = new NetworkStream(socket, ownsSocket: false);
Backchannel\GetTerminalInfoAsyncTests.cs (1)
471var stream = new NetworkStream(client, ownsSocket: true);
Aspire.Managed.Tests (1)
TerminalHostSignalTests.cs (1)
136using var stream = new NetworkStream(client);
Aspire.TerminalHost (3)
Hmp1UdsServerListenerFilter.cs (1)
135var stream = new NetworkStream(socket, ownsSocket: true);
TerminalHostControlListener.cs (1)
197await using var stream = new NetworkStream(client, ownsSocket: true);
TerminalReplica.cs (1)
611return new NetworkStream(socket, ownsSocket: true);
Aspire.TerminalHost.Tests (5)
TerminalHostAppTests.cs (5)
217var stream = new NetworkStream(socket, ownsSocket: false); 922_stream = new NetworkStream(socket, ownsSocket: true); 1068_stream = new NetworkStream(socket, ownsSocket: true); 1215var stream = new NetworkStream(socket, ownsSocket: true); 1260await using var producer = new NetworkStream(socket, ownsSocket: false);
Microsoft.AspNetCore.InternalTesting (1)
HttpClientSlim.cs (1)
153var stream = new NetworkStream(socket, ownsSocket: true);
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)
717stream = new NetworkStream(socket, ownsSocket: true);
System.Net.HttpListener (2)
System\Net\Managed\HttpConnection.cs (2)
84_stream = new NetworkStream(sock, false); 94_sslStream = HttpListener.CreateSslStream(new NetworkStream(sock, false), false, (t, c, ch, e) =>
System.Net.Requests (4)
System\Net\FtpControlStream.cs (1)
182_dataStream = new NetworkStream(_dataSocket, true);
System\Net\FtpWebRequest.cs (2)
960result = new FtpControlStream(new NetworkStream(client, ownsSocket: true)); 986return new FtpControlStream(new NetworkStream(client, ownsSocket: true));
System\Net\HttpWebRequest.cs (1)
1881return new NetworkStream(socket, ownsSocket: true);
System.Net.Sockets (1)
System\Net\Sockets\TCPClient.cs (1)
256return _dataStream ??= new NetworkStream(Client, true);
89 references to NetworkStream
aspire (2)
Backchannel\AppHostAuxiliaryBackchannel.cs (1)
186var stream = new NetworkStream(socket, ownsSocket: true);
Backchannel\AppHostCliBackchannel.cs (1)
337var stream = new NetworkStream(socket, true);
aspire-managed (1)
TerminalHostForwarder.cs (1)
136using var stream = new NetworkStream(socket);
Aspire.Cli.EndToEnd.Tests (5)
Helpers\KubernetesDeployTestHelpersTests.cs (5)
116private readonly Func<int, NetworkStream, CancellationToken, Task> _respond; 121private FakeDownloadServer(Func<int, NetworkStream, CancellationToken, Task> respond) => _respond = respond; 127public static FakeDownloadServer Start(Func<int, NetworkStream, CancellationToken, Task> respond) 156var stream = client.GetStream(); 191public static Task WriteResponseAsync(this NetworkStream stream, string status, string body, CancellationToken cancellationToken)
Aspire.Cli.Tests (7)
Backchannel\AppHostAuxiliaryBackchannelTests.cs (1)
141var serverStream = new NetworkStream(serverSocket, ownsSocket: true);
Backchannel\AppHostCliBackchannelTests.cs (1)
179var stream = new NetworkStream(socket, ownsSocket: true);
Backchannel\AppHostConnectionResolverTests.cs (1)
714var stream = new NetworkStream(serverSocket, ownsSocket: true);
Commands\PsCommandTests.cs (1)
860var serverStream = new NetworkStream(serverSocket, ownsSocket: true);
Projects\RunningInstanceManagerTests.cs (1)
91var serverStream = new NetworkStream(serverSocket, ownsSocket: true);
TestServices\GitAuthenticationServer.cs (1)
34await using var stream = client.GetStream();
TestServices\TestAuxiliaryBackchannelServer.cs (1)
29var stream = new NetworkStream(socket, ownsSocket: true);
Aspire.Hosting (5)
Backchannel\AuxiliaryBackchannelService.cs (1)
144using var stream = new NetworkStream(ownedClientSocket, ownsSocket: false);
Backchannel\BackchannelService.cs (1)
77var stream = new NetworkStream(clientSocket, true);
Backchannel\TerminalHostControlClient.cs (1)
66var stream = new NetworkStream(socket, ownsSocket: true);
Dcp\DcpHost.cs (2)
560using var stream = new NetworkStream(socket, ownsSocket: true); 561using var _ = cancellationToken.Register(s => ((NetworkStream)s!).Close(), stream);
Aspire.Hosting.Azure.Kusto.Tests (1)
AzureKustoHealthCheckTests.cs (1)
85var stream = client.GetStream();
Aspire.Hosting.Browsers.Tests (1)
BrowserLogsSessionManagerTests.cs (1)
585await using var stream = client.GetStream();
Aspire.Hosting.Native.Client (1)
NativeClient.cs (1)
32private NativeClient(NetworkStream stream, TimeProvider clock)
Aspire.Hosting.Native.Core.Tests (4)
TestServices\NativeActivationRpcTestHost.cs (1)
32using var stream = new NetworkStream(socket, ownsSocket: false);
TestServices\NativeAuxiliaryTestHost.cs (1)
65var stream = new NetworkStream(socket, ownsSocket: true);
TestServices\NativeCliTestHost.cs (1)
38var stream = new NetworkStream(socket, ownsSocket: true);
TestServices\RedisProtocolTestClient.cs (1)
17await using var stream = client.GetStream();
Aspire.Hosting.Native.Server (1)
Transport\SocketConnectionListener.cs (1)
58using var stream = new NetworkStream(socket, ownsSocket: false);
Aspire.Hosting.RemoteHost (1)
JsonRpcServer.cs (1)
228var stream = new NetworkStream(clientSocket, ownsSocket: true);
Aspire.Hosting.Tests (15)
Backchannel\AppHostBackchannelTests.cs (2)
66using var stream = new NetworkStream(socket, true); 102using var stream = new NetworkStream(socket, true);
Backchannel\AuxiliaryBackchannelTests.cs (12)
136using var stream = new NetworkStream(socket, ownsSocket: false); 170using var stream = new NetworkStream(socket, ownsSocket: true); 205using var stream = new NetworkStream(socket, ownsSocket: true); 248using var stream = new NetworkStream(socket, ownsSocket: true); 290using var stream = new NetworkStream(socket, ownsSocket: true); 370using var stream = new NetworkStream(socket, ownsSocket: true); 411using var stream = new NetworkStream(socket, ownsSocket: true); 448using var stream = new NetworkStream(socket, ownsSocket: true); 498using var stream = new NetworkStream(socket, ownsSocket: true); 539using var stream = new NetworkStream(socket, ownsSocket: true); 582using var stream = new NetworkStream(socket, ownsSocket: true); 626using var stream = new NetworkStream(socket, ownsSocket: false);
Backchannel\GetTerminalInfoAsyncTests.cs (1)
471var stream = new NetworkStream(client, ownsSocket: true);
Aspire.Managed.Tests (1)
TerminalHostSignalTests.cs (1)
136using var stream = new NetworkStream(client);
Aspire.Seq.Tests (1)
SeqEndpointCanBeConfigured.cs (1)
109await using var stream = client.GetStream();
Aspire.TerminalHost (2)
Hmp1UdsServerListenerFilter.cs (1)
135var stream = new NetworkStream(socket, ownsSocket: true);
TerminalHostControlListener.cs (1)
197await using var stream = new NetworkStream(client, ownsSocket: true);
Aspire.TerminalHost.Tests (5)
TerminalHostAppTests.cs (5)
217var stream = new NetworkStream(socket, ownsSocket: false); 916private readonly NetworkStream _stream; 1060private readonly NetworkStream _stream; 1215var stream = new NetworkStream(socket, ownsSocket: true); 1260await using var producer = new NetworkStream(socket, ownsSocket: false);
Infrastructure.Tests (4)
PowerShellScripts\DownloadNativeArchivesTests.cs (4)
587var stream = client.GetStream(); 602private static async Task<string?> ReadRequestPathAsync(NetworkStream stream, CancellationToken token) 631private static void WriteResponse(NetworkStream stream, int statusCode, string? contentType, byte[] body, int? bodyBytesToWrite = null) 649private void HandleRequest(TcpClient client, NetworkStream stream, string path)
Microsoft.AspNetCore.Components.WebAssembly.Server (4)
TargetPickerUi.cs (4)
51static async Task SendMessageToBrowser(NetworkStream toStream, ExpandoObject args, CancellationToken token) 61var toStream = browserDebugClientConnect.GetStream(); 98static async Task EvaluateOnBrowser(NetworkStream toStream, string? to, string text, CancellationToken token) 138var toStream = browserDebugClientConnect.GetStream();
Microsoft.AspNetCore.InternalTesting (1)
HttpClientSlim.cs (1)
153var stream = new NetworkStream(socket, ownsSocket: true);
Microsoft.TestPlatform.CommunicationUtilities (2)
SocketCommunicationManager.cs (2)
127var networkStream = client.GetStream(); 193var networkStream = _tcpClient.GetStream();
netstandard (1)
netstandard.cs (1)
1263[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Sockets.NetworkStream))]
System (1)
parent\ref\System.cs (1)
753[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Sockets.NetworkStream))]
System.Net.Http (2)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)
672static IPEndPoint? GetRemoteEndPoint(Stream stream) => (stream as NetworkStream)?.Socket?.RemoteEndPoint as IPEndPoint;
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (1)
146if (!async && _stream is NetworkStream networkStream)
System.Net.Requests (7)
System\Net\CommandStream.cs (1)
41internal CommandStream(NetworkStream client)
System\Net\FtpControlStream.cs (2)
32private NetworkStream? _dataStream; 79internal FtpControlStream(NetworkStream client)
System\Net\FtpDataStream.cs (2)
20private readonly NetworkStream _originalStream; 28internal FtpDataStream(Stream stream, NetworkStream originalStream, FtpWebRequest request, TriState writeOnly)
System\Net\NetworkStreamWrapper.cs (2)
15private NetworkStream _networkStream; 18internal NetworkStreamWrapper(NetworkStream stream)
System.Net.Security (1)
System\Net\Security\NetEventSource.Security.cs (1)
53if (innerStream is NetworkStream ns)
System.Net.Sockets (13)
System\Net\Sockets\NetworkStream.cs (10)
252if (GetType() != typeof(NetworkStream)) 324if (GetType() != typeof(NetworkStream)) 351/// <summary>Closes the <see cref="NetworkStream"/> after waiting the specified time to allow data to be sent.</summary> 355/// The Close method frees both unmanaged and managed resources associated with the <see cref="NetworkStream"/>. 356/// If the <see cref="NetworkStream"/> owns the underlying <see cref="Socket"/>, it is closed as well. 357/// If a <see cref="NetworkStream"/> was associated with a <see cref="TcpClient"/>, the <see cref="Close(int)"/> method 367/// <summary>Closes the <see cref="NetworkStream"/> after waiting the specified time to allow data to be sent.</summary> 371/// The Close method frees both unmanaged and managed resources associated with the <see cref="NetworkStream"/>. 372/// If the <see cref="NetworkStream"/> owns the underlying <see cref="Socket"/>, it is closed as well. 373/// If a <see cref="NetworkStream"/> was associated with a <see cref="TcpClient"/>, the <see cref="Close(int)"/> method
System\Net\Sockets\TCPClient.cs (3)
19private NetworkStream? _dataStream; 247public NetworkStream GetStream() 268NetworkStream? dataStream = _dataStream;