206 types derived from Stream
BasicWebSite (2)
dotnet-svcutil-lib (9)
http2cat (1)
IIS.FunctionalTests (1)
IIS.LongTests (1)
IIS.NewHandler.FunctionalTests (1)
IIS.NewShim.FunctionalTests (1)
IIS.ShadowCopy.Tests (1)
IISExpress.FunctionalTests (1)
InMemory.FunctionalTests (1)
Microsoft.AspNetCore.Components.Server (3)
Microsoft.AspNetCore.Components.Web (1)
Microsoft.AspNetCore.Components.WebAssembly (1)
Microsoft.AspNetCore.Components.WebView (2)
Microsoft.AspNetCore.Components.WebView.WindowsForms (1)
Microsoft.AspNetCore.Components.WebView.Wpf (1)
Microsoft.AspNetCore.Http (1)
Microsoft.AspNetCore.Http.Connections (2)
Microsoft.AspNetCore.Http.Connections.Client (1)
Microsoft.AspNetCore.Http.Connections.Tests (1)
Microsoft.AspNetCore.Http.Extensions.Tests (4)
Microsoft.AspNetCore.Http.Microbenchmarks (1)
Microsoft.AspNetCore.Http.Tests (1)
Microsoft.AspNetCore.HttpLogging (1)
Microsoft.AspNetCore.Mvc.Core (1)
Microsoft.AspNetCore.Mvc.Core.Test (1)
Microsoft.AspNetCore.Mvc.Core.TestCommon (1)
Microsoft.AspNetCore.Mvc.FunctionalTests (1)
Microsoft.AspNetCore.OpenApi (1)
Microsoft.AspNetCore.OutputCaching (1)
Microsoft.AspNetCore.RequestDecompression (1)
Microsoft.AspNetCore.ResponseCaching (2)
Microsoft.AspNetCore.ResponseCompression (1)
Microsoft.AspNetCore.ResponseCompression.Tests (2)
Microsoft.AspNetCore.Routing.FunctionalTests (1)
Microsoft.AspNetCore.Server.HttpSys (4)
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)
Microsoft.AspNetCore.Server.IIS (6)
Microsoft.AspNetCore.Server.Kestrel.Core (8)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (2)
Microsoft.AspNetCore.Shared.Tests (2)
Microsoft.AspNetCore.SignalR.Client.Core (1)
Microsoft.AspNetCore.SignalR.Client.Tests (2)
Microsoft.AspNetCore.SignalR.Common (1)
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (1)
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (1)
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
Microsoft.AspNetCore.SignalR.StackExchangeRedis (1)
Microsoft.AspNetCore.TestHost (3)
Microsoft.AspNetCore.WebSockets (1)
Microsoft.AspNetCore.WebSockets.Tests (2)
Microsoft.AspNetCore.WebUtilities (4)
Microsoft.AspNetCore.WebUtilities.Microbenchmarks (1)
Microsoft.AspNetCore.WebUtilities.Tests (2)
Microsoft.Build (3)
Microsoft.Build.Tasks.UnitTests (2)
Microsoft.CodeAnalysis (4)
Microsoft.CodeAnalysis.CodeStyle (1)
Microsoft.CodeAnalysis.CSharp.Emit.UnitTests (1)
Microsoft.CodeAnalysis.Test.Utilities (2)
Microsoft.CodeAnalysis.Workspaces (1)
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (2)
Microsoft.CodeAnalysis.Workspaces.Test.Utilities (1)
Microsoft.DotNet.Build.Tasks.Feed.Tests (1)
Microsoft.DotNet.Helix.Client (1)
Microsoft.Extensions.Http.Diagnostics.PerformanceTests (1)
Microsoft.Extensions.Http.Diagnostics.Tests (1)
Microsoft.Maui.Controls (1)
Microsoft.ML.Core (3)
Microsoft.ML.Data (1)
Microsoft.ML.FastTree (1)
Microsoft.ML.Tests (1)
MSBuild (1)
MSBuildTaskHost (1)
PresentationBuildTasks (1)
PresentationCore (4)
PresentationFramework (7)
PresentationUI (2)
ScenarioTests.Common.Tests (3)
System.ComponentModel.TypeConverter (1)
System.Console (1)
System.Data.Common (2)
System.Drawing.Common.Tests (1)
System.Formats.Tar (1)
System.IO.Compression (10)
System.IO.Compression.Brotli (3)
System.IO.Packaging (3)
System.IO.Pipelines (2)
System.IO.Pipes (2)
System.IO.Ports (2)
System.Memory.Data (1)
System.Net.Http (5)
System.Net.Http.Json (1)
System.Net.HttpListener (4)
System.Net.Mail (1)
System.Net.Quic (1)
System.Net.Requests (4)
System.Net.Security (1)
System.Net.Sockets (1)
System.Net.WebClient (2)
System.Private.CoreLib (8)
System.Private.DataContractSerialization (2)
System.Security.Cryptography (1)
System.ServiceModel.NetFramingBase (1)
System.Windows.Forms (1)
5923 references to Stream
ApiExplorerWebSite (1)
Aspire.Azure.Messaging.EventHubs.Tests (1)
Aspire.Azure.Security.KeyVault.Tests (1)
Aspire.Confluent.Kafka.Tests (4)
Aspire.Hosting (5)
Aspire.Hosting.Tests (3)
Aspire.RabbitMQ.Client.Tests (2)
Aspire.RabbitMQ.Client.v7.Tests (2)
AzureFunctionsEndToEnd.ApiService (1)
BasicTestApp (3)
BasicWebSite (2)
BicepSample.ApiService (1)
BinaryFormatTests (1)
Binding.Http.IntegrationTests (2)
BuildBoss (3)
Contract.Service.IntegrationTests (28)
csc (6)
dotnet-openapi (6)
dotnet-razorpagegenerator (1)
dotnet-svcutil-lib (304)
FrameworkFork\Microsoft.Xml\Xml\Core\XmlTextReaderImpl.cs (21)
129public Stream inputStream;
464internal XmlTextReaderImpl(Stream input) : this(string.Empty, input, new NameTable())
467internal XmlTextReaderImpl(Stream input, XmlNameTable nt) : this(string.Empty, input, nt)
470internal XmlTextReaderImpl(string url, Stream input) : this(url, input, new NameTable())
473internal XmlTextReaderImpl(string url, Stream input, XmlNameTable nt) : this(nt)
512internal XmlTextReaderImpl(Stream xmlFragment, XmlNodeType fragType, XmlParserContext context)
649Stream stream = null;
662stream = (Stream)_laterInitParam.inputUriResolver.GetEntity(_laterInitParam.inputbaseUri, string.Empty, typeof(Stream));
700internal XmlTextReaderImpl(Stream stream, byte[] bytes, int byteCount, XmlReaderSettings settings, Uri baseUri, string baseUriStr,
2874private void InitStreamInput(Stream stream, Encoding encoding)
2879private void InitStreamInput(string baseUriStr, Stream stream, Encoding encoding)
2885private void InitStreamInput(Uri baseUri, Stream stream, Encoding encoding)
2891private void InitStreamInput(Uri baseUri, string baseUriStr, Stream stream, Encoding encoding)
2896private void InitStreamInput(Uri baseUri, string baseUriStr, Stream stream, byte[] bytes, int byteCount, Encoding encoding)
3160_ps.stream = (Stream)GetTempResolver().GetEntity(_ps.baseUri, null, typeof(Stream));
8110Debug.Assert(_xmlResolver.SupportsType(uri, typeof(Stream)), "Stream must always be a supported type in XmlResolver");
8112Stream stream = (Stream)_xmlResolver.GetEntity(uri, null, typeof(Stream));
FrameworkFork\System.Runtime.Serialization\System\Xml\XmlDictionaryReader.cs (6)
63public static XmlDictionaryReader CreateBinaryReader(Stream stream, XmlDictionaryReaderQuotas quotas)
68public static XmlDictionaryReader CreateBinaryReader(Stream stream, IXmlDictionary dictionary, XmlDictionaryReaderQuotas quotas)
73public static XmlDictionaryReader CreateBinaryReader(Stream stream, IXmlDictionary dictionary, XmlDictionaryReaderQuotas quotas, XmlBinaryReaderSession session)
94static public XmlDictionaryReader CreateTextReader(Stream stream, XmlDictionaryReaderQuotas quotas)
99static public XmlDictionaryReader CreateTextReader(Stream stream, Encoding encoding,
124public virtual void StartCanonicalization(Stream stream, bool includeComments, string[] inclusivePrefixes)
FrameworkFork\System.Runtime.Serialization\System\Xml\XmlDictionaryWriter.cs (8)
21static public XmlDictionaryWriter CreateBinaryWriter(Stream stream)
26static public XmlDictionaryWriter CreateBinaryWriter(Stream stream, IXmlDictionary dictionary)
31static public XmlDictionaryWriter CreateBinaryWriter(Stream stream, IXmlDictionary dictionary, XmlBinaryWriterSession session)
36static public XmlDictionaryWriter CreateBinaryWriter(Stream stream, IXmlDictionary dictionary, XmlBinaryWriterSession session, bool ownsStream)
44static public XmlDictionaryWriter CreateTextWriter(Stream stream)
49static public XmlDictionaryWriter CreateTextWriter(Stream stream, Encoding encoding)
54static public XmlDictionaryWriter CreateTextWriter(Stream stream, Encoding encoding, bool ownsStream)
197public virtual void StartCanonicalization(Stream stream, bool includeComments, string[] inclusivePrefixes)
FrameworkFork\System.ServiceModel\System\IdentityModel\CanonicalFormWriter.cs (5)
18protected static void EncodeAndWrite(Stream stream, byte[] workBuffer, string s)
43protected static void EncodeAndWrite(Stream stream, byte[] workBuffer, char[] chars)
48protected static void EncodeAndWrite(Stream stream, byte[] workBuffer, char[] chars, int count)
73private static void EncodeAndWrite(Stream stream, string s)
79private static void EncodeAndWrite(Stream stream, char[] chars, int count)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageEncoder.cs (8)
32public Message ReadMessage(Stream stream, int maxSizeOfHeaders)
37public virtual Task<Message> ReadMessageAsync(Stream stream, int maxSizeOfHeaders, string contentType)
47public abstract Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType);
58internal async Task<ArraySegment<byte>> BufferMessageStreamAsync(Stream stream, BufferManager bufferManager, int maxBufferSize)
93internal virtual async Task<Message> ReadMessageAsync(Stream stream, BufferManager bufferManager, int maxBufferSize, string contentType)
103public abstract void WriteMessage(Message message, Stream stream);
105public virtual IAsyncResult BeginWriteMessage(Message message, Stream stream, AsyncCallback callback, object state)
124public virtual Task WriteMessageAsync(Message message, Stream stream)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageEncoderCompressionHandler.cs (14)
29using (Stream ds = compressionFormat == CompressionFormat.GZip ?
30(Stream)new GZipStream(memoryStream, CompressionMode.Decompress) :
31(Stream)new DeflateStream(memoryStream, CompressionMode.Decompress))
65using (Stream ds = compressionFormat == CompressionFormat.GZip ?
66(Stream)new GZipStream(bufferedOutStream, CompressionMode.Compress, true) :
67(Stream)new DeflateStream(bufferedOutStream, CompressionMode.Compress, true))
79internal static Stream GetDecompressStream(Stream compressedStream, CompressionFormat compressionFormat)
82(Stream)new GZipStream(compressedStream, CompressionMode.Decompress, false) :
83(Stream)new DeflateStream(compressedStream, CompressionMode.Decompress, false);
86internal static Stream GetCompressStream(Stream uncompressedStream, CompressionFormat compressionFormat)
89(Stream)new GZipStream(uncompressedStream, CompressionMode.Compress, true) :
90(Stream)new DeflateStream(uncompressedStream, CompressionMode.Compress, true);
FrameworkFork\System.ServiceModel\System\ServiceModel\Description\MessageContractImporter.cs (3)
691return CheckAndAddPart(element.ElementSchemaType.QualifiedName, DataContractSerializerMessageContractImporter.StreamBodyTypeName, element.RefName.Name, GetLocalElementNamespace(element.RefName.Namespace, element, elementFormDefault), typeof(Stream), description, isReply);
695return CheckAndAddPart(element.SchemaTypeName, DataContractSerializerMessageContractImporter.StreamBodyTypeName, element.Name, GetLocalElementNamespace(ns, element, elementFormDefault), typeof(Stream), description, isReply);
708return CheckAndAddPart(typeName, DataContractSerializerMessageContractImporter.StreamBodyTypeName, part.Name, ns, typeof(Stream), description, isReply);
EventHubsApi (1)
Extensibility.MessageEncoder.IntegrationTests (4)
Extensibility.WebSockets.IntegrationTests (3)
FormatterWebSite (6)
http2cat (4)
HttpStress (4)
IdeBenchmarks (1)
IIS.Common.TestLib (1)
IIS.FunctionalTests (5)
IIS.LongTests (5)
IIS.NewHandler.FunctionalTests (5)
IIS.NewShim.FunctionalTests (5)
IIS.ShadowCopy.Tests (5)
IISExpress.FunctionalTests (5)
illink (17)
ILLink.Tasks (1)
InMemory.FunctionalTests (57)
src\Servers\Kestrel\shared\test\StreamExtensions.cs (4)
15public static async Task<int> FillBufferUntilEndAsync(this Stream stream, byte[] buffer, CancellationToken cancellationToken = default)
34public static async Task<int> FillEntireBufferAsync(this Stream stream, byte[] buffer, CancellationToken cancellationToken = default)
49public static async Task<byte[]> ReadAtLeastLengthAsync(this Stream stream, int length, int bufferLength = 1024, bool allowEmpty = false, CancellationToken cancellationToken = default)
76public static async Task<byte[]> ReadUntilEndAsync(this Stream stream, int bufferLength = 1024, CancellationToken cancellationToken = default)
InProcessWebSite (2)
Interop.FunctionalTests (42)
src\Servers\Kestrel\shared\test\StreamExtensions.cs (4)
15public static async Task<int> FillBufferUntilEndAsync(this Stream stream, byte[] buffer, CancellationToken cancellationToken = default)
34public static async Task<int> FillEntireBufferAsync(this Stream stream, byte[] buffer, CancellationToken cancellationToken = default)
49public static async Task<byte[]> ReadAtLeastLengthAsync(this Stream stream, int length, int bufferLength = 1024, bool allowEmpty = false, CancellationToken cancellationToken = default)
76public static async Task<byte[]> ReadUntilEndAsync(this Stream stream, int bufferLength = 1024, CancellationToken cancellationToken = default)
Kestrel.SampleApp (1)
Microsoft.Arcade.Common (7)
Microsoft.Arcade.Test.Common (1)
Microsoft.AspNetCore.App.Analyzers.Test (2)
Microsoft.AspNetCore.Authentication.Test (1)
Microsoft.AspNetCore.Authentication.Twitter (1)
Microsoft.AspNetCore.Components.Endpoints (1)
Microsoft.AspNetCore.Components.Endpoints.Tests (14)
Binding\FormDataMapperTests.cs (10)
1904var expected = new FormFile(Stream.Null, 0, 10, "file", "file.txt");
1929new FormFile(Stream.Null, 0, 10, "file", "file-1.txt"),
1930new FormFile(Stream.Null, 0, 20, "file", "file-2.txt"),
1931new FormFile(Stream.Null, 0, 30, "file", "file-3.txt"),
1932new FormFile(Stream.Null, 0, 40, "oddOneOutFile", "file-4.txt"),
1962new FormFile(Stream.Null, 0, 10, "file", "file-1.txt"),
1963new FormFile(Stream.Null, 0, 20, "file", "file-2.txt"),
1964new FormFile(Stream.Null, 0, 30, "file", "file-3.txt"),
1965new FormFile(Stream.Null, 0, 40, "oddOneOutFile", "file-4.txt"),
1988var expected = new FormFileCollection { new FormFile(Stream.Null, 0, 10, "file", "file.txt") };
Microsoft.AspNetCore.Components.Server (6)
Microsoft.AspNetCore.Components.Web (8)
Microsoft.AspNetCore.Components.Web.Tests (2)
Microsoft.AspNetCore.Components.WebAssembly (2)
Microsoft.AspNetCore.Components.WebView (10)
Microsoft.AspNetCore.Components.WebView.Maui (4)
Microsoft.AspNetCore.Components.WebView.Photino (3)
Microsoft.AspNetCore.Components.WebView.Test (2)
Microsoft.AspNetCore.Components.WebView.WindowsForms (4)
Microsoft.AspNetCore.Components.WebView.Wpf (4)
Microsoft.AspNetCore.Diagnostics (1)
Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore (1)
Microsoft.AspNetCore.Diagnostics.Tests (2)
Microsoft.AspNetCore.Grpc.JsonTranscoding (3)
Microsoft.AspNetCore.Grpc.JsonTranscoding.Tests (1)
Microsoft.AspNetCore.Hosting (7)
Microsoft.AspNetCore.Hosting.Tests (3)
Microsoft.AspNetCore.Http (28)
Microsoft.AspNetCore.Http.Abstractions (5)
Microsoft.AspNetCore.Http.Connections (7)
Microsoft.AspNetCore.Http.Connections.Client (4)
Microsoft.AspNetCore.Http.Connections.Tests (8)
Microsoft.AspNetCore.Http.Extensions (15)
Microsoft.AspNetCore.Http.Extensions.Tests (13)
RequestDelegateFactoryTests.FormMapping.cs (3)
293new FormFile(Stream.Null, 0, 10, "file", "file.txt"),
294new FormFile(Stream.Null, 0, 10, "formFiles", "file-1.txt"),
295new FormFile(Stream.Null, 0, 10, "formFiles", "file-2.txt"),
Microsoft.AspNetCore.Http.Features (12)
Microsoft.AspNetCore.Http.Results (33)
Results.cs (9)
351/// Writes the specified <see cref="System.IO.Stream"/> to the response.
357/// This API is an alias for <see cref="Stream(Stream, string, string?, DateTimeOffset?, EntityTagHeaderValue?, bool)"/>.
360/// <param name="fileStream">The <see cref="System.IO.Stream"/> with the contents of the file.</param>
373Stream fileStream,
382/// Writes the specified <see cref="System.IO.Stream"/> to the response.
388/// This API is an alias for <see cref="File(Stream, string, string?, DateTimeOffset?, EntityTagHeaderValue?, bool)"/>.
391/// <param name="stream">The <see cref="System.IO.Stream"/> to write to the response.</param>
404Stream stream,
452Func<Stream, Task> streamWriterCallback,
TypedResults.cs (9)
341/// Writes the specified <see cref="System.IO.Stream"/> to the response.
347/// This API is an alias for <see cref="Stream(Stream, string, string?, DateTimeOffset?, EntityTagHeaderValue?, bool)"/>.
353/// <param name="fileStream">The <see cref="System.IO.Stream"/> with the contents of the file.</param>
363Stream fileStream,
382/// Writes the specified <see cref="System.IO.Stream"/> to the response.
388/// This API is an alias for <see cref="File(Stream, string, string?, DateTimeOffset?, EntityTagHeaderValue?, bool)"/>.
394/// <param name="stream">The <see cref="System.IO.Stream"/> to write to the response.</param>
404Stream stream,
472Func<Stream, Task> streamWriterCallback,
Microsoft.AspNetCore.Http.Results.Tests (23)
Microsoft.AspNetCore.Http.Tests (31)
Internal\ReferenceReadStreamTests.cs (9)
13var stream = new ReferenceReadStream(Mock.Of<Stream>(), 0, 1);
20var stream = new ReferenceReadStream(Mock.Of<Stream>(), 0, 1);
27var stream = new ReferenceReadStream(Mock.Of<Stream>(), 0, 1);
34var stream = new ReferenceReadStream(Mock.Of<Stream>(), 0, 1);
41var stream = new ReferenceReadStream(Mock.Of<Stream>(), 0, 1);
48var stream = new ReferenceReadStream(Mock.Of<Stream>(), 0, 1);
55var stream = new ReferenceReadStream(Mock.Of<Stream>(), 0, 1);
62var stream = new ReferenceReadStream(Mock.Of<Stream>(), 0, 1);
69var stream = new ReferenceReadStream(Mock.Of<Stream>(), 0, 1);
Microsoft.AspNetCore.HttpLogging (7)
Microsoft.AspNetCore.HttpLogging.Tests (7)
Microsoft.AspNetCore.Identity (2)
Microsoft.AspNetCore.Identity.Test (1)
Microsoft.AspNetCore.InternalTesting (4)
Microsoft.AspNetCore.Mvc.Abstractions (5)
Microsoft.AspNetCore.Mvc.Core (45)
ControllerBase.cs (16)
1222/// <param name="fileStream">The <see cref="Stream"/> with the contents of the file.</param>
1229public virtual FileStreamResult File(Stream fileStream, string contentType)
1238/// <param name="fileStream">The <see cref="Stream"/> with the contents of the file.</param>
1246public virtual FileStreamResult File(Stream fileStream, string contentType, bool enableRangeProcessing)
1256/// <param name="fileStream">The <see cref="Stream"/> with the contents of the file.</param>
1264public virtual FileStreamResult File(Stream fileStream, string contentType, string? fileDownloadName)
1274/// <param name="fileStream">The <see cref="Stream"/> with the contents of the file.</param>
1283public virtual FileStreamResult File(Stream fileStream, string contentType, string? fileDownloadName, bool enableRangeProcessing)
1296/// <param name="fileStream">The <see cref="Stream"/> with the contents of the file.</param>
1305public virtual FileStreamResult File(Stream fileStream, string contentType, DateTimeOffset? lastModified, EntityTagHeaderValue entityTag)
1320/// <param name="fileStream">The <see cref="Stream"/> with the contents of the file.</param>
1330public virtual FileStreamResult File(Stream fileStream, string contentType, DateTimeOffset? lastModified, EntityTagHeaderValue entityTag, bool enableRangeProcessing)
1346/// <param name="fileStream">The <see cref="Stream"/> with the contents of the file.</param>
1356public virtual FileStreamResult File(Stream fileStream, string contentType, string? fileDownloadName, DateTimeOffset? lastModified, EntityTagHeaderValue entityTag)
1372/// <param name="fileStream">The <see cref="Stream"/> with the contents of the file.</param>
1383public virtual FileStreamResult File(Stream fileStream, string contentType, string? fileDownloadName, DateTimeOffset? lastModified, EntityTagHeaderValue entityTag, bool enableRangeProcessing)
Microsoft.AspNetCore.Mvc.Core.Test (42)
ModelBinding\FormFileValueProviderTest.cs (3)
18formFiles.Add(new FormFile(Stream.Null, 0, 0, "file", fileName: null));
37formFiles.Add(new FormFile(Stream.Null, 0, 10, "file", "file"));
56formFiles.Add(new FormFile(Stream.Null, 0, 10, "file", "file"));
Microsoft.AspNetCore.Mvc.Core.TestCommon (4)
Microsoft.AspNetCore.Mvc.Formatters.Xml (10)
Microsoft.AspNetCore.Mvc.Formatters.Xml.Test (25)
Microsoft.AspNetCore.Mvc.FunctionalTests (12)
Microsoft.AspNetCore.Mvc.NewtonsoftJson (3)
Microsoft.AspNetCore.Mvc.NewtonsoftJson.Test (19)
Microsoft.AspNetCore.Mvc.Razor (1)
Microsoft.AspNetCore.Mvc.Razor.RuntimeCompilation (4)
Microsoft.AspNetCore.Mvc.Razor.RuntimeCompilation.Test (2)
Microsoft.AspNetCore.Mvc.RazorPages (8)
Microsoft.AspNetCore.Mvc.RazorPages.Test (8)
Microsoft.AspNetCore.Mvc.TagHelpers (2)
Microsoft.AspNetCore.Mvc.TagHelpers.Test (4)
Microsoft.AspNetCore.Mvc.Test (1)
Microsoft.AspNetCore.Mvc.Testing (3)
Microsoft.AspNetCore.Mvc.ViewFeatures.Test (4)
Microsoft.AspNetCore.Mvc.Views.TestCommon (4)
Microsoft.AspNetCore.OpenApi (5)
Microsoft.AspNetCore.OpenApi.Tests (4)
Microsoft.AspNetCore.OutputCaching (3)
Microsoft.AspNetCore.OutputCaching.Microbenchmarks (5)
EndToEndBenchmarks.cs (5)
78static void WriteInRandomChunks(ReadOnlySpan<byte> value, Stream destination)
106static async Task WriteInRandomChunksAsync(ReadOnlyMemory<byte> value, Stream destination, CancellationToken cancellationToken)
122using (var oc = new OutputCacheStream(Stream.Null, _options.MaximumBodySize, StreamUtilities.BodySegmentSize, _noop))
138using (var oc = new OutputCacheStream(Stream.Null, _options.MaximumBodySize, StreamUtilities.BodySegmentSize, _noop))
154using (var oc = new OutputCacheStream(Stream.Null, _options.MaximumBodySize, StreamUtilities.BodySegmentSize, _noop))
Microsoft.AspNetCore.Owin (12)
OwinEnvironment.cs (4)
60{ OwinConstants.RequestBody, new FeatureMap<IHttpRequestFeature>(feature => feature.Body, () => Stream.Null, (feature, value) => feature.Body = (Stream)value) },
66{ OwinConstants.ResponseBody, new FeatureMap<IHttpResponseBodyFeature>(feature => feature.Stream, () => Stream.Null, (feature, value) => context.Response.Body = (Stream)value) }, // DefaultHttpResponse.Body.Set has built in logic to handle replacing the feature.
Microsoft.AspNetCore.Owin.Tests (10)
Microsoft.AspNetCore.RequestDecompression (15)
Microsoft.AspNetCore.RequestDecompression.Tests (19)
Microsoft.AspNetCore.ResponseCaching (3)
Microsoft.AspNetCore.ResponseCaching.Microbenchmarks (1)
Microsoft.AspNetCore.ResponseCompression (11)
Microsoft.AspNetCore.ResponseCompression.Tests (13)
Microsoft.AspNetCore.Rewrite (2)
Microsoft.AspNetCore.Routing.FunctionalTests (2)
Microsoft.AspNetCore.Server.HttpSys (18)
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (22)
Microsoft.AspNetCore.Server.IIS (33)
Microsoft.AspNetCore.Server.IntegrationTesting (1)
Microsoft.AspNetCore.Server.IntegrationTesting.IIS (2)
Microsoft.AspNetCore.Server.Kestrel.Core (35)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (18)
src\Servers\Kestrel\shared\test\StreamExtensions.cs (4)
15public static async Task<int> FillBufferUntilEndAsync(this Stream stream, byte[] buffer, CancellationToken cancellationToken = default)
34public static async Task<int> FillEntireBufferAsync(this Stream stream, byte[] buffer, CancellationToken cancellationToken = default)
49public static async Task<byte[]> ReadAtLeastLengthAsync(this Stream stream, int length, int bufferLength = 1024, bool allowEmpty = false, CancellationToken cancellationToken = default)
76public static async Task<byte[]> ReadUntilEndAsync(this Stream stream, int bufferLength = 1024, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (4)
src\Servers\Kestrel\shared\test\StreamExtensions.cs (4)
15public static async Task<int> FillBufferUntilEndAsync(this Stream stream, byte[] buffer, CancellationToken cancellationToken = default)
34public static async Task<int> FillEntireBufferAsync(this Stream stream, byte[] buffer, CancellationToken cancellationToken = default)
49public static async Task<byte[]> ReadAtLeastLengthAsync(this Stream stream, int length, int bufferLength = 1024, bool allowEmpty = false, CancellationToken cancellationToken = default)
76public static async Task<byte[]> ReadUntilEndAsync(this Stream stream, int bufferLength = 1024, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Session (9)
Microsoft.AspNetCore.Shared.Tests (4)
Microsoft.AspNetCore.SignalR.Client.Tests (10)
Microsoft.AspNetCore.SignalR.Common (2)
Microsoft.AspNetCore.SignalR.Microbenchmarks (5)
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (2)
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (2)
Microsoft.AspNetCore.SignalR.Specification.Tests (2)
Microsoft.AspNetCore.SignalR.StackExchangeRedis (2)
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (1)
Microsoft.AspNetCore.SpaServices.Extensions (1)
Microsoft.AspNetCore.StaticAssets (3)
Microsoft.AspNetCore.StaticAssets.Tests (2)
Microsoft.AspNetCore.StaticFiles.FunctionalTests (2)
Microsoft.AspNetCore.StaticFiles.Tests (8)
Microsoft.AspNetCore.TestHost (8)
Microsoft.AspNetCore.TestHost.Tests (22)
Microsoft.AspNetCore.Tests (3)
Microsoft.AspNetCore.WebSockets (3)
Microsoft.AspNetCore.WebSockets.Tests (5)
Microsoft.AspNetCore.WebUtilities (69)
Microsoft.AspNetCore.WebUtilities.Tests (41)
FormReaderTests.cs (16)
16var body = MakeStream(bufferRequest, "=bar");
28var body = MakeStream(bufferRequest, "=bar&baz=2");
41var body = MakeStream(bufferRequest, "foo=");
53var body = MakeStream(bufferRequest, "foo=&baz=2");
66var body = MakeStream(bufferRequest, "foo=1&bar=2&baz=3");
81var body = MakeStream(bufferRequest, "foo=1&baz=2&bar=3&baz=4&baf=5");
93var body = MakeStream(bufferRequest, "baz=1&baz=2&baz=3&baz=4");
105var body = MakeStream(bufferRequest, "foo=1&bar=2&baz=3&baz=4");
120var body = MakeStream(bufferRequest, "foo=1&baz1234567890=2");
132var body = MakeStream(bufferRequest, "foo=1&bar=1234567890&baz=3&baz=4");
147var body = MakeStream(bufferRequest, "foo=1&baz=1234567890123");
159var body = MakeStream(bufferRequest, "foo=&baz=2");
181var body = MakeStream(bufferRequest, "");
198var body = MakeStream(bufferRequest: false, text: formData);
215private static Stream MakeStream(bool bufferRequest, string text)
218Stream body = new MemoryStream(formContent);
Microsoft.Build (78)
BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (8)
164Stream nodeStream = TryConnectToProcess(nodeProcess.Id, timeout, NodeProviderOutOfProc.GetHandshake(nodeReuse, false));
284Stream nodeStream = TryConnectToProcess(nodeToReuse.Id, 0 /* poll, don't wait for connections */, hostHandshake);
344Stream nodeStream = TryConnectToProcess(msbuildProcess.Id, TimeoutForNewNodeCreation, hostHandshake);
379void CreateNodeContext(int nodeId, Process nodeToReuse, Stream nodeStream)
443private Stream TryConnectToProcess(int nodeProcessId, int timeout, Handshake handshake)
539private Stream _clientToServerStream;
540private Stream _serverToClientStream;
607Stream nodePipe,
FileUtilities.cs (3)
1409Stream fileStream = new FileStream(path, mode, FileAccess.Write, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1423Stream fileStream = new FileStream(path, FileMode.Open, FileAccess.Read, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1533internal static void ReadFromStream(this Stream stream, byte[] content, int startIndex, int length)
Microsoft.Build.Engine.OM.UnitTests (7)
FileUtilities.cs (3)
1409Stream fileStream = new FileStream(path, mode, FileAccess.Write, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1423Stream fileStream = new FileStream(path, FileMode.Open, FileAccess.Read, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1533internal static void ReadFromStream(this Stream stream, byte[] content, int startIndex, int length)
Microsoft.Build.Engine.UnitTests (1)
Microsoft.Build.Framework (9)
Microsoft.Build.Tasks.CodeAnalysis (7)
Microsoft.Build.Tasks.Core (100)
FileUtilities.cs (3)
1409Stream fileStream = new FileStream(path, mode, FileAccess.Write, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1423Stream fileStream = new FileStream(path, FileMode.Open, FileAccess.Read, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1533internal static void ReadFromStream(this Stream stream, byte[] content, int startIndex, int length)
ManifestUtil\TrustInfo.cs (13)
436using (Stream s = File.Open(path, FileMode.Open, FileAccess.Read, FileShare.Read))
446public void Read(Stream input)
451private void Read(Stream s, string xpath)
475using (Stream s = File.Open(path, FileMode.Open, FileAccess.Read, FileShare.Read))
485public void ReadManifest(Stream input)
548using (Stream s = File.Open(path, FileMode.Create, FileAccess.Write, FileShare.None))
559public void Write(Stream output)
631Stream s = tempPrivilegeDocument != null ? XmlUtil.XslTransform(trustInfoResource2, m, new DictionaryEntry("defaultRequestedPrivileges", tempPrivilegeDocument)) : XmlUtil.XslTransform(trustInfoResource2, m);
651Stream s = null;
689public void WriteManifest(Stream output)
692Stream input = Util.GetEmbeddedResourceStream(r);
701public void WriteManifest(Stream input, Stream output)
Microsoft.Build.Tasks.UnitTests (22)
Microsoft.Build.UnitTests.Shared (3)
Microsoft.Build.Utilities.Core (7)
FileUtilities.cs (3)
1409Stream fileStream = new FileStream(path, mode, FileAccess.Write, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1423Stream fileStream = new FileStream(path, FileMode.Open, FileAccess.Read, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1533internal static void ReadFromStream(this Stream stream, byte[] content, int startIndex, int length)
Microsoft.Cci.Extensions (5)
Microsoft.CodeAnalysis (229)
CommandLine\CommonCompiler.cs (22)
213var peStream = FileSystem.OpenFileWithNormalizedException(path, FileMode.Open, FileAccess.Read, FileShare.Read);
275using var data = Console.OpenStandardInput();
281using var data = OpenFileForReadWithSmallBufferOptimization(filePath, out normalizedFilePath);
371var data = OpenFileForReadWithSmallBufferOptimization(filePath, out normalizedPath);
385private Stream OpenFileForReadWithSmallBufferOptimization(string filePath, out string normalizedFilePath)
402using (var stream = OpenFileForReadWithSmallBufferOptimization(filePath, out _))
723var errorLog = OpenFile(Arguments.ErrorLogOptions.Path,
1183var fileStream = OpenFile(path, diagnostics, FileMode.Create, FileAccess.Write, FileShare.ReadWrite | FileShare.Delete);
1272var sourceLinkStreamOpt = OpenFile(
1345var xmlStreamOpt = OpenFile(finalXmlFilePath,
1374using (var win32ResourceStreamOpt = GetWin32Resources(FileSystem, MessageProvider, Arguments, compilation, diagnostics))
1564var readStream = OpenFile(readFilesPath, diagnostics, mode: FileMode.OpenOrCreate);
1565var writtenStream = OpenFile(writtenFilesPath, diagnostics, mode: FileMode.OpenOrCreate);
1620private Stream? OpenFile(
1639internal static Stream? GetWin32ResourcesInternal(
1647var stream = GetWin32Resources(fileSystem, messageProvider, arguments, compilation, diagnostics);
1652private static Stream? GetWin32Resources(
1664using (Stream? manifestStream = OpenManifestStream(fileSystem, messageProvider, compilation.Options.OutputKind, arguments, diagnostics))
1666using (Stream? iconStream = OpenStream(fileSystem, messageProvider, arguments.Win32Icon, arguments.BaseDirectory, messageProvider.ERR_CantOpenWin32Icon, diagnostics))
1682private static Stream? OpenManifestStream(ICommonCompilerFileSystem fileSystem, CommonMessageProvider messageProvider, OutputKind outputKind, CommandLineArguments arguments, DiagnosticBag diagnostics)
1689private static Stream? OpenStream(ICommonCompilerFileSystem fileSystem, CommonMessageProvider messageProvider, string? path, string? baseDirectory, int errorCode, DiagnosticBag diagnostics)
1754using var stream = fileSystem.OpenFile(filePath, FileMode.Create, FileAccess.ReadWrite, FileShare.None);
Compilation.EmitStream.cs (13)
43/// and then copied back to the original <see cref="Stream"/>. Only when legacy signing is enabled though.
51private (Stream emitStream, Stream tempStream, string tempFilePath)? _tempInfo;
68internal Func<Stream?> GetCreateStreamFunc(CommonMessageProvider messageProvider, DiagnosticBag diagnostics)
77if (_tempInfo is (Stream _, Stream tempStream, string tempFilePath))
102/// The <see cref="Stream"/> returned here is owned by this type and should not be disposed
105private Stream? CreateStream(CommonMessageProvider messageProvider, DiagnosticBag diagnostics)
135var emitStream = _emitStreamProvider.GetOrCreateStream(diagnostics);
141Stream tempStream;
145Func<string, Stream> streamConstructor = path => fileSystem.CreateFileStream(path, FileMode.Create, FileAccess.ReadWrite, FileShare.ReadWrite);
173if (_tempInfo is (Stream emitStream, Stream tempStream, string tempFilePath))
Compilation\Compilation.cs (67)
1920public Stream CreateDefaultWin32Resources(bool versionResource, bool noManifest, Stream? manifestContents, Stream? iconInIcoFormat)
1966internal static void AppendNullResource(Stream resourceStream)
1982protected abstract void AppendDefaultVersionResource(Stream resourceStream);
1991internal static Win32ResourceForm DetectWin32ResourceForm(Stream win32Resources)
2009internal Cci.ResourceSection? MakeWin32ResourcesFromCOFF(Stream? win32Resources, DiagnosticBag diagnostics)
2041internal List<Win32Resource>? MakeWin32ResourceList(Stream? win32Resources, DiagnosticBag diagnostics)
2086internal void SetupWin32Resources(CommonPEModuleBuilder moduleBeingBuilt, Stream? win32Resources, bool useRawWin32Resources, DiagnosticBag diagnostics)
2476Stream? sourceLinkStream,
2574Stream? win32Resources,
2584Stream? xmlDocStream,
2678Stream peStream,
2679Stream? pdbStream,
2680Stream? xmlDocumentationStream,
2681Stream? win32Resources,
2702Stream peStream,
2703Stream pdbStream,
2704Stream xmlDocumentationStream,
2705Stream win32Resources,
2726Stream peStream,
2727Stream? pdbStream,
2728Stream? xmlDocumentationStream,
2729Stream? win32Resources,
2733Stream? sourceLinkStream,
2787Stream peStream,
2788Stream? pdbStream = null,
2789Stream? xmlDocumentationStream = null,
2790Stream? win32Resources = null,
2794Stream? sourceLinkStream = null,
2796Stream? metadataPEStream = null,
2815Stream peStream,
2816Stream? pdbStream,
2817Stream? xmlDocumentationStream,
2818Stream? win32Resources,
2822Stream? sourceLinkStream,
2824Stream? metadataPEStream,
2932Stream peStream,
2933Stream? metadataPEStream,
2934Stream? pdbStream,
2935Stream? xmlDocumentationStream,
2936Stream? win32Resources,
2940Stream? sourceLinkStream,
3046Stream metadataStream,
3047Stream ilStream,
3048Stream pdbStream,
3067Stream metadataStream,
3068Stream ilStream,
3069Stream pdbStream,
3094Stream metadataStream,
3095Stream ilStream,
3096Stream pdbStream,
3140Stream metadataStream,
3141Stream ilStream,
3142Stream pdbStream,
3155Stream? sourceLinkStream,
3271Func<Stream?>? getPortablePdbStream =
3274: (Func<Stream?>)(() => ConditionalGetOrCreateStream(pdbStreamProvider, metadataDiagnostics));
3297var nativePdbStream = pdbStreamProvider!.GetOrCreateStream(metadataDiagnostics);
3348private static Stream? ConditionalGetOrCreateStream(EmitStreamProvider metadataPEStreamProvider, DiagnosticBag metadataDiagnostics)
3355var auxStream = metadataPEStreamProvider.GetOrCreateStream(metadataDiagnostics);
3364Func<Stream?> getPeStream,
3365Func<Stream?>? getMetadataPeStreamOpt,
3366Func<Stream?>? getPortablePdbStreamOpt,
3427Stream metadataStream,
3428Stream ilStream,
3429Stream pdbStream,
EncodedStringText.cs (7)
54/// from <see cref="SourceText.From(Stream, Encoding, SourceHashAlgorithm, bool)"/> in two ways:
72internal static SourceText Create(Stream stream,
84internal static SourceText Create(Stream stream,
128Stream data,
167internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes)
230internal static SourceText Create(Stream stream, Lazy<Encoding> getEncoding, Encoding defaultEncoding, SourceHashAlgorithm checksumAlgorithm, bool canBeEmbedded)
233internal static SourceText Decode(Stream data, Encoding encoding, SourceHashAlgorithm checksumAlgorithm, bool throwIfBinaryDetected, bool canBeEmbedded)
FileSystem\ICommonCompilerFileSystem.cs (5)
18Stream OpenFile(string filePath, FileMode mode, FileAccess access, FileShare share);
20Stream OpenFileEx(string filePath, FileMode mode, FileAccess access, FileShare share, int bufferSize, FileOptions options, out string normalizedFilePath);
28internal static Stream OpenFileWithNormalizedException(this ICommonCompilerFileSystem fileSystem, string filePath, FileMode fileMode, FileAccess fileAccess, FileShare fileShare)
63public Stream OpenFile(string filePath, FileMode mode, FileAccess access, FileShare share)
66public Stream OpenFileEx(string filePath, FileMode mode, FileAccess access, FileShare share, int bufferSize, FileOptions options, out string normalizedFilePath)
ResourceDescription.cs (5)
24internal readonly Func<Stream> DataProvider;
38public ResourceDescription(string resourceName, Func<Stream> dataProvider, bool isPublic)
55public ResourceDescription(string resourceName, string? fileName, Func<Stream> dataProvider, bool isPublic)
60internal ResourceDescription(string resourceName, string? fileName, Func<Stream> dataProvider, bool isPublic, bool isEmbedded, bool checkArgs)
114using (var stream = _resource.DataProvider())
Text\SourceText.cs (8)
154public static SourceText From(Stream stream, Encoding? encoding, SourceHashAlgorithm checksumAlgorithm, bool throwIfBinaryDetected)
181Stream stream,
290private static string Decode(Stream stream, Encoding encoding, out Encoding actualEncoding)
425/// <see cref="From(Stream, Encoding, SourceHashAlgorithm, bool, bool)"/>, then the canBeEmbedded arg must have
577/// take a <c>byte[]</c> or <see cref="Stream"/>). Otherwise, computed by writing this <see cref="SourceText"/>
578/// back to a <see cref="Stream"/> (using the provided <see cref="Encoding"/>), and computing the hash off of
692internal static ImmutableArray<byte> CalculateChecksum(Stream stream, SourceHashAlgorithm algorithmId)
1289internal static int GetMaxCharCountOrThrowIfHuge(Encoding encoding, Stream stream)
Microsoft.CodeAnalysis.CodeStyle (29)
src\Compilers\Core\Portable\EncodedStringText.cs (7)
54/// from <see cref="SourceText.From(Stream, Encoding, SourceHashAlgorithm, bool)"/> in two ways:
72internal static SourceText Create(Stream stream,
84internal static SourceText Create(Stream stream,
128Stream data,
167internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes)
230internal static SourceText Create(Stream stream, Lazy<Encoding> getEncoding, Encoding defaultEncoding, SourceHashAlgorithm checksumAlgorithm, bool canBeEmbedded)
233internal static SourceText Decode(Stream data, Encoding encoding, SourceHashAlgorithm checksumAlgorithm, bool throwIfBinaryDetected, bool canBeEmbedded)
Microsoft.CodeAnalysis.Compiler.Test.Resources (4)
Microsoft.CodeAnalysis.CSharp (13)
Microsoft.CodeAnalysis.CSharp.CommandLine.UnitTests (7)
Microsoft.CodeAnalysis.CSharp.EditorFeatures.UnitTests (2)
Microsoft.CodeAnalysis.CSharp.EditorFeatures2.UnitTests (1)
Microsoft.CodeAnalysis.CSharp.Emit.UnitTests (20)
Microsoft.CodeAnalysis.CSharp.Emit2.UnitTests (1)
Microsoft.CodeAnalysis.CSharp.Emit3.UnitTests (1)
Microsoft.CodeAnalysis.CSharp.EndToEnd.UnitTests (1)
Microsoft.CodeAnalysis.CSharp.Scripting (4)
Microsoft.CodeAnalysis.CSharp.Scripting.UnitTests (2)
Microsoft.CodeAnalysis.CSharp.Semantic.UnitTests (1)
Microsoft.CodeAnalysis.CSharp.Symbol.UnitTests (1)
Microsoft.CodeAnalysis.EditorFeatures (4)
Microsoft.CodeAnalysis.EditorFeatures.Test.Utilities (6)
Microsoft.CodeAnalysis.EditorFeatures.UnitTests (8)
Microsoft.CodeAnalysis.ExpressionEvaluator.ExpressionCompiler (1)
Microsoft.CodeAnalysis.Features (31)
Microsoft.CodeAnalysis.Features.Test.Utilities (7)
Microsoft.CodeAnalysis.InteractiveHost (6)
Microsoft.CodeAnalysis.LanguageServer (3)
Microsoft.CodeAnalysis.LanguageServer.Protocol.UnitTests (2)
Microsoft.CodeAnalysis.Rebuild (9)
Microsoft.CodeAnalysis.Remote.ServiceHub (2)
Microsoft.CodeAnalysis.Scripting (12)
Microsoft.CodeAnalysis.Test.Utilities (19)
TestableFileSystem.cs (4)
13public delegate Stream OpenFileExFunc(string filePath, FileMode mode, FileAccess access, FileShare share, int bufferSize, FileOptions options, out string normalizedFilePath);
14public delegate Stream OpenFileFunc(string filePath, FileMode mode, FileAccess access, FileShare share);
32public Stream OpenFile(string filePath, FileMode mode, FileAccess access, FileShare share)
35public Stream OpenFileEx(string filePath, FileMode mode, FileAccess access, FileShare share, int bufferSize, FileOptions options, out string normalizedFilePath)
Microsoft.CodeAnalysis.UnitTests (6)
Microsoft.CodeAnalysis.VisualBasic (13)
Microsoft.CodeAnalysis.VisualBasic.Emit.UnitTests (8)
Microsoft.CodeAnalysis.VisualBasic.Semantic.UnitTests (1)
Microsoft.CodeAnalysis.Workspaces (152)
src\Compilers\Core\Portable\EncodedStringText.cs (7)
54/// from <see cref="SourceText.From(Stream, Encoding, SourceHashAlgorithm, bool)"/> in two ways:
72internal static SourceText Create(Stream stream,
84internal static SourceText Create(Stream stream,
128Stream data,
167internal static bool TryGetBytesFromStream(Stream data, out ArraySegment<byte> bytes)
230internal static SourceText Create(Stream stream, Lazy<Encoding> getEncoding, Encoding defaultEncoding, SourceHashAlgorithm checksumAlgorithm, bool canBeEmbedded)
233internal static SourceText Decode(Stream data, Encoding encoding, SourceHashAlgorithm checksumAlgorithm, bool throwIfBinaryDetected, bool canBeEmbedded)
Storage\SQLite\v2\SQLitePersistentStorage.Accessor.cs (5)
137public Task<Stream?> ReadStreamAsync(TKey key, string name, Checksum? checksum, CancellationToken cancellationToken)
143private Stream? ReadStream(TKey key, string name, Checksum? checksum, CancellationToken cancellationToken)
217public Task<bool> WriteStreamAsync(TKey key, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
222private bool WriteStream(TKey key, string dataName, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
262private Optional<Stream> ReadDataBlob(
Workspace\Host\PersistentStorage\AbstractPersistentStorage.cs (27)
47public abstract Task<Stream?> ReadStreamAsync(string name, Checksum? checksum, CancellationToken cancellationToken);
48public abstract Task<bool> WriteStreamAsync(string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken);
52protected abstract Task<Stream?> ReadStreamAsync(ProjectKey projectKey, Project? project, string name, Checksum? checksum, CancellationToken cancellationToken);
53protected abstract Task<Stream?> ReadStreamAsync(DocumentKey documentKey, Document? document, string name, Checksum? checksum, CancellationToken cancellationToken);
54protected abstract Task<bool> WriteStreamAsync(ProjectKey projectKey, Project? project, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken);
55protected abstract Task<bool> WriteStreamAsync(DocumentKey documentKey, Document? document, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken);
63public Task<Stream?> ReadStreamAsync(ProjectKey projectKey, string name, Checksum? checksum, CancellationToken cancellationToken)
64=> IsDisabled ? SpecializedTasks.Null<Stream>() : ReadStreamAsync(projectKey, project: null, name, checksum, cancellationToken);
66public Task<Stream?> ReadStreamAsync(DocumentKey documentKey, string name, Checksum? checksum, CancellationToken cancellationToken)
67=> IsDisabled ? SpecializedTasks.Null<Stream>() : ReadStreamAsync(documentKey, document: null, name, checksum, cancellationToken);
69public Task<bool> WriteStreamAsync(ProjectKey projectKey, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
72public Task<bool> WriteStreamAsync(DocumentKey documentKey, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
81public Task<Stream?> ReadStreamAsync(Project project, string name, Checksum? checksum, CancellationToken cancellationToken)
82=> IsDisabled ? SpecializedTasks.Null<Stream>() : ReadStreamAsync(ProjectKey.ToProjectKey(project), project, name, checksum, cancellationToken);
84public Task<Stream?> ReadStreamAsync(Document document, string name, Checksum? checksum, CancellationToken cancellationToken)
85=> IsDisabled ? SpecializedTasks.Null<Stream>() : ReadStreamAsync(DocumentKey.ToDocumentKey(document), document, name, checksum, cancellationToken);
87public Task<Stream?> ReadStreamAsync(string name, CancellationToken cancellationToken)
88=> IsDisabled ? SpecializedTasks.Null<Stream>() : ReadStreamAsync(name, checksum: null, cancellationToken);
90public Task<Stream?> ReadStreamAsync(Project project, string name, CancellationToken cancellationToken)
91=> IsDisabled ? SpecializedTasks.Null<Stream>() : ReadStreamAsync(project, name, checksum: null, cancellationToken);
93public Task<Stream?> ReadStreamAsync(Document document, string name, CancellationToken cancellationToken)
94=> IsDisabled ? SpecializedTasks.Null<Stream>() : ReadStreamAsync(document, name, checksum: null, cancellationToken);
96public Task<bool> WriteStreamAsync(Project project, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
99public Task<bool> WriteStreamAsync(Document document, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
102public Task<bool> WriteStreamAsync(string name, Stream stream, CancellationToken cancellationToken)
105public Task<bool> WriteStreamAsync(Project project, string name, Stream stream, CancellationToken cancellationToken)
108public Task<bool> WriteStreamAsync(Document document, string name, Stream stream, CancellationToken cancellationToken)
Workspace\Host\PersistentStorage\IChecksummedPersistentStorage.cs (10)
45Task<Stream?> ReadStreamAsync(string name, Checksum? checksum = null, CancellationToken cancellationToken = default);
52Task<Stream?> ReadStreamAsync(Project project, string name, Checksum? checksum = null, CancellationToken cancellationToken = default);
59Task<Stream?> ReadStreamAsync(Document document, string name, Checksum? checksum = null, CancellationToken cancellationToken = default);
61Task<Stream?> ReadStreamAsync(ProjectKey project, string name, Checksum? checksum = null, CancellationToken cancellationToken = default);
62Task<Stream?> ReadStreamAsync(DocumentKey document, string name, Checksum? checksum = null, CancellationToken cancellationToken = default);
73Task<bool> WriteStreamAsync(string name, Stream stream, Checksum? checksum = null, CancellationToken cancellationToken = default);
84Task<bool> WriteStreamAsync(Project project, string name, Stream stream, Checksum? checksum = null, CancellationToken cancellationToken = default);
95Task<bool> WriteStreamAsync(Document document, string name, Stream stream, Checksum? checksum = null, CancellationToken cancellationToken = default);
101Task<bool> WriteStreamAsync(ProjectKey projectKey, string name, Stream stream, Checksum? checksum = null, CancellationToken cancellationToken = default);
107Task<bool> WriteStreamAsync(DocumentKey documentKey, string name, Stream stream, Checksum? checksum = null, CancellationToken cancellationToken = default);
Workspace\Host\PersistentStorage\IPersistentStorage.cs (6)
18Task<Stream?> ReadStreamAsync(string name, CancellationToken cancellationToken = default);
19Task<Stream?> ReadStreamAsync(Project project, string name, CancellationToken cancellationToken = default);
20Task<Stream?> ReadStreamAsync(Document document, string name, CancellationToken cancellationToken = default);
26Task<bool> WriteStreamAsync(string name, Stream stream, CancellationToken cancellationToken = default);
32Task<bool> WriteStreamAsync(Project project, string name, Stream stream, CancellationToken cancellationToken = default);
38Task<bool> WriteStreamAsync(Document document, string name, Stream stream, CancellationToken cancellationToken = default);
Workspace\Host\PersistentStorage\NoOpPersistentStorage.cs (24)
38public Task<Stream?> ReadStreamAsync(Document document, string name, CancellationToken cancellationToken)
39=> SpecializedTasks.Null<Stream>();
41public Task<Stream?> ReadStreamAsync(Project project, string name, CancellationToken cancellationToken)
42=> SpecializedTasks.Null<Stream>();
44public Task<Stream?> ReadStreamAsync(string name, CancellationToken cancellationToken)
45=> SpecializedTasks.Null<Stream>();
47public Task<Stream?> ReadStreamAsync(string name, Checksum? checksum, CancellationToken cancellationToken)
48=> SpecializedTasks.Null<Stream>();
50public Task<Stream?> ReadStreamAsync(Project project, string name, Checksum? checksum, CancellationToken cancellationToken)
51=> SpecializedTasks.Null<Stream>();
53public Task<Stream?> ReadStreamAsync(Document document, string name, Checksum? checksum, CancellationToken cancellationToken)
54=> SpecializedTasks.Null<Stream>();
56public Task<Stream?> ReadStreamAsync(ProjectKey project, string name, Checksum? checksum, CancellationToken cancellationToken)
57=> SpecializedTasks.Null<Stream>();
59public Task<Stream?> ReadStreamAsync(DocumentKey document, string name, Checksum? checksum, CancellationToken cancellationToken)
60=> SpecializedTasks.Null<Stream>();
62public Task<bool> WriteStreamAsync(Document document, string name, Stream stream, CancellationToken cancellationToken)
65public Task<bool> WriteStreamAsync(Project project, string name, Stream stream, CancellationToken cancellationToken)
68public Task<bool> WriteStreamAsync(string name, Stream stream, CancellationToken cancellationToken)
71public Task<bool> WriteStreamAsync(string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
74public Task<bool> WriteStreamAsync(Project project, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
77public Task<bool> WriteStreamAsync(Document document, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
80public Task<bool> WriteStreamAsync(ProjectKey projectKey, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
83public Task<bool> WriteStreamAsync(DocumentKey documentKey, string name, Stream stream, Checksum? checksum, CancellationToken cancellationToken)
Microsoft.CodeAnalysis.Workspaces.MSBuild (2)
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (11)
Microsoft.CodeAnalysis.Workspaces.MSBuild.UnitTests (5)
Microsoft.CodeAnalysis.Workspaces.Test.Utilities (3)
Microsoft.CodeAnalysis.Workspaces.UnitTests (7)
Microsoft.CommonLanguageServerProtocol.Framework.UnitTests (1)
Microsoft.Data.Analysis (11)
Microsoft.Data.Analysis.Tests (10)
Microsoft.DotNet.Build.Tasks.Feed (7)
Microsoft.DotNet.Build.Tasks.Installers (20)
Microsoft.DotNet.Build.Tasks.Packaging (3)
Microsoft.DotNet.Build.Tasks.VisualStudio (3)
Microsoft.DotNet.Build.Tasks.Workloads (1)
Microsoft.DotNet.Helix.Client (7)
Microsoft.DotNet.Helix.JobSender (4)
Microsoft.DotNet.Helix.JobSender.Tests (1)
Microsoft.DotNet.Helix.Sdk (2)
Microsoft.DotNet.Internal.SymbolHelper (6)
Microsoft.DotNet.NuGetRepack.Tasks (6)
Microsoft.DotNet.NuGetRepack.Tests (4)
Microsoft.DotNet.Open.Api.Tools.Tests (2)
Microsoft.DotNet.SignCheckLibrary (7)
Microsoft.DotNet.SignTool (20)
Microsoft.DotNet.SignTool.Tests (7)
Microsoft.DotNet.SourceBuild.Tasks (1)
Microsoft.DotNet.SwaggerGenerator.CmdLine (1)
Microsoft.DotNet.SwaggerGenerator.CodeGenerator (1)
Microsoft.DotNet.SwaggerGenerator.MSBuild (1)
Microsoft.DotNet.VersionTools (5)
Microsoft.DotNet.XliffTasks (4)
Microsoft.Extensions.AI.Integration.Tests (1)
Microsoft.Extensions.AI.Ollama (1)
Microsoft.Extensions.AI.OpenAI (13)
src\Shared\ServerSentEvents\SseFormatter.cs (3)
30public static Task WriteAsync(IAsyncEnumerable<SseItem<string>> source, Stream destination, CancellationToken cancellationToken = default)
54public static Task WriteAsync<T>(IAsyncEnumerable<SseItem<T>> source, Stream destination, Action<SseItem<T>, IBufferWriter<byte>> itemFormatter, CancellationToken cancellationToken = default)
74private static async Task WriteAsyncCore<T>(IAsyncEnumerable<SseItem<T>> source, Stream destination, Action<SseItem<T>, IBufferWriter<byte>> itemFormatter, CancellationToken cancellationToken)
Microsoft.Extensions.Configuration (2)
Microsoft.Extensions.Configuration.FileExtensions (3)
Microsoft.Extensions.Configuration.Ini (6)
Microsoft.Extensions.Configuration.Json (7)
Microsoft.Extensions.Configuration.KeyPerFile (1)
Microsoft.Extensions.Configuration.KeyPerFile.Tests (1)
Microsoft.Extensions.Configuration.Xml (8)
Microsoft.Extensions.DependencyModel (12)
Microsoft.Extensions.FileProviders.Abstractions (2)
Microsoft.Extensions.FileProviders.Embedded (12)
Microsoft.Extensions.FileProviders.Embedded.Tests (4)
Microsoft.Extensions.FileProviders.Physical (2)
Microsoft.Extensions.Http.Diagnostics (4)
Microsoft.Extensions.Http.Diagnostics.Tests (6)
Microsoft.Extensions.Localization (1)
Microsoft.Extensions.Localization.Tests (3)
Microsoft.Extensions.Logging.AzureAppServices (1)
Microsoft.Extensions.Logging.Console (3)
Microsoft.Extensions.ML (1)
Microsoft.JSInterop (11)
Microsoft.Maui (12)
Microsoft.Maui.Controls (21)
Microsoft.Maui.Controls.Build.Tasks (2)
Microsoft.Maui.Controls.Compatibility (4)
Microsoft.Maui.Controls.SourceGen (1)
Microsoft.Maui.Controls.Xaml (3)
Microsoft.Maui.Essentials (19)
Microsoft.Maui.Graphics (19)
Microsoft.Maui.Graphics.Skia (9)
Microsoft.Maui.Graphics.Win2D.WinUI.Desktop (5)
Microsoft.Maui.Resizetizer (4)
Microsoft.ML.AutoML (4)
Microsoft.ML.AutoML.Tests (1)
Microsoft.ML.CodeAnalyzer.Tests (2)
Microsoft.ML.Core (43)
Data\Repository.cs (15)
60public Stream Stream { get; }
62internal Entry(Repository rep, string path, Stream stream)
272protected Entry AddEntry(string pathEnt, Stream stream)
289private Queue<KeyValuePair<string, Stream>> _closed;
291public static RepositoryWriter CreateNew(Stream stream, IExceptionContext ectx = null, bool useFileSystem = true)
303private RepositoryWriter(Stream stream, IExceptionContext ectx, bool useFileSystem = true)
307_closed = new Queue<KeyValuePair<string, Stream>>();
327Stream stream;
344_closed.Enqueue(new KeyValuePair<string, Stream>(ent.Path, ent.Stream));
390using (var src = kvp.Value)
397using (var dst = ae.Open())
450public static RepositoryReader Open(Stream stream, IExceptionContext ectx = null, bool useFileSystem = true)
457private RepositoryReader(Stream stream, IExceptionContext ectx, bool useFileSystem)
508Stream stream;
542using (var src = entry.Open())
Utilities\Stream.cs (6)
19public static void CloseEx(this Stream stream)
41public static long CopyRange(this Stream source, Stream destination, long length, int bufferSize = 81920)
877public static void ReadBlock(this Stream s, byte[] buff, int offset, int length)
896public static int TryReadBlock(this Stream s, byte[] buff, int offset, int length)
936public static StreamWriter OpenWriter(Stream stream, Encoding encoding = null, int bufferSize = 1024, bool leaveOpen = true)
Microsoft.ML.Data (159)
Commands\SavePredictorCommand.cs (18)
84using (var binStrm = CreateStrm(binFile))
86using (var sumStrm = CreateStrm(sumFile))
88using (var txtStrm = CreateStrm(txtFile))
90using (var iniStrm = CreateStrm(iniFile))
92using (var codStrm = CreateStrm(codFile))
109private Stream CreateStrm(IFileHandle file)
120public static void SavePredictor(IHostEnvironment env, Stream modelStream, Stream binaryModelStream = null, Stream summaryModelStream = null,
121Stream textModelStream = null, Stream iniModelStream = null, Stream codeModelStream = null)
142Stream binaryModelStream = null, Stream summaryModelStream = null, Stream textModelStream = null,
143Stream iniModelStream = null, Stream codeModelStream = null)
207public static void LoadModel(IHostEnvironment env, Stream modelStream, bool loadNames, out IPredictor predictor, out RoleMappedSchema schema)
DataLoadSave\Binary\BinaryLoader.cs (15)
233Stream stream = _parent._stream;
304Stream stream = _parent._stream;
317private void ReadTocMetadata(IChannel ch, Stream stream)
612Stream stream = Parent._stream;
619using (var decompressed = Compression.DecompressStream(subset))
671private readonly Stream _stream;
763private BinaryLoader(Arguments args, IHost host, Stream stream, bool leaveOpen)
803internal BinaryLoader(IHostEnvironment env, Arguments args, Stream stream, bool leaveOpen = true)
823private BinaryLoader(IHost host, ModelLoadContext ctx, Stream stream)
919private static BinaryLoader Create(IHostEnvironment env, ModelLoadContext ctx, Stream stream)
926private static Stream OpenStream(IMultiStreamSource files)
933private static Stream OpenStream(string filename)
1420Stream stream = _parent._stream;
1680private readonly Stream _stream;
1890using (Stream stream = _compression.DecompressStream(buffer))
DataLoadSave\Binary\BinarySaver.cs (14)
31private static readonly FuncInstanceMethodInfo1<BinarySaver, Stream, IValueCodec, object> _loadValueMethodInfo
32= FuncInstanceMethodInfo1<BinarySaver, Stream, IValueCodec, object>.Create(target => target.LoadValue<int>);
226using (Stream stream = _compression.CompressStream(compressed))
348private delegate IValueCodec WriteMetadataCoreDelegate(Stream stream, DataViewSchema schema, int col, string kind, DataViewType type, out CompressionKind compression);
350private IValueCodec WriteMetadataCore<T>(Stream stream, DataViewSchema schema, int col, string kind, DataViewType type, out CompressionKind compressionKind)
376using (Stream compressStream = _compression.CompressStream(compressedMem))
396private void WriteWorker(Stream stream, BlockingCollection<Block> toWrite, ColumnCodec[] activeColumns,
643public void SaveData(Stream stream, IDataView data, params int[] colIndices)
784IValueWriter<T> specificWriter = codec.OpenWriter(Stream.Null);
805public bool TryWriteTypeDescription(Stream stream, DataViewType type, out int bytesWritten)
829public DataViewType LoadTypeDescriptionOrNull(Stream stream)
847public bool TryWriteTypeAndValue<T>(Stream stream, DataViewType type, ref T value, out int bytesWritten)
882public bool TryLoadTypeAndValue(Stream stream, out DataViewType type, out object value)
902private object LoadValue<T>(Stream stream, IValueCodec codec)
DataLoadSave\Binary\Codecs.cs (45)
24protected Stream Stream;
29public ValueWriterBase(CodecFactory factory, Stream stream)
68protected Stream Stream;
73public ValueReaderBase(CodecFactory factory, Stream stream)
130public bool GetCodec(Stream definitionStream, out IValueCodec codec)
136public int WriteParameterization(Stream stream)
142public abstract IValueWriter<T> OpenWriter(Stream stream);
144public abstract IValueReader<T> OpenReader(Stream stream, int items);
173public override IValueWriter<T> OpenWriter(Stream stream)
178public override IValueReader<T> OpenReader(Stream stream, int items)
189public Writer(UnsafeTypeCodec<T> codec, Stream stream)
240public Reader(UnsafeTypeCodec<T> codec, Stream stream, int items)
303public override IValueWriter<ReadOnlyMemory<char>> OpenWriter(Stream stream)
308public override IValueReader<ReadOnlyMemory<char>> OpenReader(Stream stream, int items)
318public Writer(TextCodec codec, Stream stream)
358public Reader(TextCodec codec, Stream stream, int items)
418public override IValueWriter<bool> OpenWriter(Stream stream)
430public Writer(BoolCodec codec, Stream stream)
470public override IValueReader<bool> OpenReader(Stream stream, int items)
481public Reader(BoolCodec codec, Stream stream, int items)
517public override IValueWriter<bool> OpenWriter(Stream stream)
523public override IValueReader<bool> OpenReader(Stream stream, int items)
534public Reader(OldBoolCodec codec, Stream stream, int items)
580public override IValueWriter<DateTime> OpenWriter(Stream stream)
585public override IValueReader<DateTime> OpenReader(Stream stream, int items)
594public Writer(DateTimeCodec codec, Stream stream)
621public Reader(DateTimeCodec codec, Stream stream, int items)
655public override IValueWriter<DateTimeOffset> OpenWriter(Stream stream)
660public override IValueReader<DateTimeOffset> OpenReader(Stream stream, int items)
670public Writer(DateTimeOffsetCodec codec, Stream stream)
717public Reader(DateTimeOffsetCodec codec, Stream stream, int items)
803public int WriteParameterization(Stream stream)
817public IValueWriter<VBuffer<T>> OpenWriter(Stream stream)
822public IValueReader<VBuffer<T>> OpenReader(Stream stream, int items)
839public Writer(VBufferCodec<T> codec, Stream stream)
976public Reader(VBufferCodec<T> codec, Stream stream, int items)
1118private bool GetVBufferCodec(Stream definitionStream, out IValueCodec codec)
1198public int WriteParameterization(Stream stream)
1220public IValueWriter<T> OpenWriter(Stream stream)
1225public IValueReader<T> OpenReader(Stream stream, int items)
1231private bool GetKeyCodecOld(Stream definitionStream, out IValueCodec codec)
1295public int WriteParameterization(Stream stream)
1317public IValueWriter<T> OpenWriter(Stream stream)
1322public IValueReader<T> OpenReader(Stream stream, int items)
1328private bool GetKeyCodec(Stream definitionStream, out IValueCodec codec)
DataLoadSave\Text\TextLoaderSaverCatalog.cs (3)
32/// If the sample has been saved with ML.NET's <see cref="SaveAsText(DataOperationsCatalog, IDataView, Stream, char, bool, bool, bool, bool)"/>,
81/// If the sample has been saved with ML.NET's <see cref="SaveAsText(DataOperationsCatalog, IDataView, Stream, char, bool, bool, bool, bool)"/>,
287Stream stream,
Model\ModelOperationsCatalog.cs (12)
35/// for an empty transformer chain. Upon loading with <see cref="LoadWithDataLoader(Stream, out IDataLoader{IMultiStreamSource})"/>
39public void Save<TSource>(ITransformer model, IDataLoader<TSource> loader, Stream stream)
61/// for an empty transformer chain. Upon loading with <see cref="LoadWithDataLoader(Stream, out IDataLoader{IMultiStreamSource})"/>
79/// for an empty transformer chain. Upon loading with <see cref="Load(Stream, out DataViewSchema)"/> the returned value will
83public void Save(ITransformer model, DataViewSchema inputSchema, Stream stream)
101/// for an empty transformer chain. Upon loading with <see cref="Load(Stream, out DataViewSchema)"/> the returned value will
152public ITransformer Load(Stream stream, out DataViewSchema inputSchema)
256/// be handled instead using the <see cref="Load(Stream, out DataViewSchema)"/> method.</param>
258public ITransformer LoadWithDataLoader(Stream stream, out IDataLoader<IMultiStreamSource> loader)
284/// be handled instead using the <see cref="Load(Stream, out DataViewSchema)"/> method.</param>
322/// It's mainly used in conjunction with <see cref="Load(Stream, out DataViewSchema)"/>,
339/// It's mainly used in conjunction with <see cref="Load(Stream, out DataViewSchema)"/>,
Microsoft.ML.Ensemble (2)
Microsoft.ML.FastTree (6)
Microsoft.ML.GenAI.Core (1)
Microsoft.ML.GenAI.Core.Tests (1)
Microsoft.ML.ImageAnalytics (2)
Microsoft.ML.IntegrationTests (1)
Microsoft.ML.LightGbm (17)
Microsoft.ML.OnnxConverter (6)
OnnxExportExtensions.cs (6)
76/// <param name="catalog">The class that <see cref="ConvertToOnnx(ModelOperationsCatalog, ITransformer, IDataView, Stream)"/> attached to.</param>
81public static void ConvertToOnnx(this ModelOperationsCatalog catalog, ITransformer transform, IDataView inputData, Stream stream) =>
87/// <param name="catalog">The class that <see cref="ConvertToOnnx(ModelOperationsCatalog, ITransformer, IDataView, int, Stream)"/> attached to.</param>
93public static void ConvertToOnnx(this ModelOperationsCatalog catalog, ITransformer transform, IDataView inputData, int opSetVersion, Stream stream) =>
99/// <param name="catalog">The class that <see cref="ConvertToOnnx(ModelOperationsCatalog, ITransformer, IDataView, Stream)"/> attached to.</param>
105public static void ConvertToOnnx(this ModelOperationsCatalog catalog, ITransformer transform, IDataView inputData, Stream stream, params string[] outputColumns) =>
Microsoft.ML.OnnxTransformer (21)
Microsoft.ML.OnnxTransformerTest (2)
Microsoft.ML.Parquet (6)
Microsoft.ML.PerformanceTests (2)
Microsoft.ML.Predictor.Tests (5)
Microsoft.ML.ResultProcessor (1)
Microsoft.ML.Samples (7)
Microsoft.ML.Samples.GPU (7)
Microsoft.ML.SamplesUtils (1)
Microsoft.ML.TestFramework (1)
Microsoft.ML.Tests (9)
Microsoft.ML.TimeSeries (2)
Microsoft.ML.Tokenizers (62)
Model\BPETokenizer.cs (11)
126using Stream vocabStream = File.OpenRead(vocabFile);
127using Stream? mergesStream = mergesFile is null ? null : File.OpenRead(mergesFile);
142public static BpeTokenizer Create(Stream vocabStream, Stream? mergesStream)
161Stream vocabStream,
162Stream? mergesStream,
197Stream vocabStream,
198Stream? mergesStream,
773internal static async ValueTask<(Dictionary<StringSpanOrdinalKey, int>?, Vec<(string, string)>)> ReadModelDataAsync(Stream vocab, Stream? merges, bool useAsync, CancellationToken cancellationToken = default)
808internal static async ValueTask<Vec<(string, string)>> ConvertMergesToHashmapAsync(Stream? mergesStream, bool useAsync = false, CancellationToken cancellationToken = default)
Model\CodeGenTokenizer.cs (8)
85Stream vocabularyStream,
86Stream mergeStream,
100private CodeGenTokenizer(Stream vocabularyStream, Stream mergeStream, PreTokenizer? preTokenizer, Normalizer? normalizer, IReadOnlyDictionary<string, int>? specialTokens, bool addPrefixSpace,
1765private static Dictionary<StringSpanOrdinalKey, (int, string)> GetVocabulary(Stream vocabularyStream)
1785internal static Dictionary<StringSpanOrdinalKeyPair, int> GetMergeRanks(Stream mergeStream)
1878Stream vocabStream,
1879Stream mergesStream,
Model\EnglishRobertaTokenizer.cs (17)
82Stream vocabularyStream,
83Stream mergeStream,
84Stream highestOccurrenceMappingStream)
101Stream vocabularyStream,
102Stream mergeStream,
103Stream highestOccurrenceMappingStream,
135internal EnglishRobertaTokenizer(Stream vocabularyStream, Stream mergeStream, Stream highestOccurrenceMappingStream, PreTokenizer? preTokenizer = null, Normalizer? normalizer = null, bool filterUnsupportedChars = true) :
140private EnglishRobertaTokenizer(Stream vocabularyStream, Stream mergeStream, Stream highestOccurrenceMappingStream, PreTokenizer? preTokenizer, Normalizer? normalizer, bool filterUnsupportedChars, bool disposeStream)
179private static Dictionary<StringSpanOrdinalKey, int> GetVocabulary(Stream vocabularyStream)
199private static Cache<(string, string), int> GetMergeRanks(Stream mergeStream)
942private static HighestOccurrenceMapping GetHighestOccurrenceMapping(Stream highestOccurrenceMappingStream) =>
1236public static HighestOccurrenceMapping Load(Stream stream)
1246public void AddFromStream(Stream stream)
Model\TiktokenTokenizer.cs (10)
61internal TiktokenTokenizer(Stream vocabStream, PreTokenizer? preTokenizer, IReadOnlyDictionary<string, int>? specialTokens = null, Normalizer? normalizer = null, int cacheSize = LruCache<int[]>.DefaultCacheSize) :
102private TiktokenTokenizer(Stream vocabStream, PreTokenizer? preTokenizer, IReadOnlyDictionary<string, int>? specialTokens, Normalizer? normalizer, int cacheSize, bool disposeStream)
158Stream vocabStream, bool useAsync, CancellationToken cancellationToken = default)
1228using Stream compressedStream = tiktokenConfiguration.DataType.Assembly!.GetManifestResourceStream(tiktokenConfiguration.VocabFile)!;
1229using Stream deflateStream = new DeflateStream(compressedStream, CompressionMode.Decompress);
1279Stream vocabStream,
1300Stream vocabStream,
1344using Stream vocabStream = File.OpenRead(vocabFilePath);
1359Stream vocabStream,
1398Stream vocabStream,
Microsoft.ML.Tokenizers.Data.Tests (2)
Microsoft.ML.Tokenizers.Tests (40)
Microsoft.ML.TorchSharp (1)
Microsoft.ML.Transforms (6)
Microsoft.ML.Vision (8)
ImageClassificationTrainer.cs (8)
887using Stream featuresWriter = File.Open(cacheFilePath + "_features.bin", FileMode.Create);
888using Stream labelWriter = File.Open(cacheFilePath + "_labels.bin", FileMode.Create);
929using (Stream trainSetLabelReader = File.Open(trainBottleneckFilePath + "_labels.bin", FileMode.Open))
930using (Stream trainSetFeatureReader = File.Open(trainBottleneckFilePath + "_features.bin", FileMode.Open))
932Stream validationSetLabelReader = validationNeeded ?
935Stream validationSetFeatureReader = validationNeeded ?
1081long[] labelTensorShape, long[] featureTensorShape, int batchSize, Stream trainSetLabelReader,
1082Stream trainSetFeatureReader, byte[] labelBufferBytes, byte[] featuresBufferBytes,
Microsoft.VisualBasic.Core (6)
Microsoft.VisualBasic.Forms (22)
Microsoft.VisualStudio.LanguageServices (8)
Microsoft.VisualStudio.LanguageServices.CSharp.UnitTests (2)
Microsoft.VisualStudio.LanguageServices.UnitTests (4)
MSBuild (17)
FileUtilities.cs (3)
1409Stream fileStream = new FileStream(path, mode, FileAccess.Write, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1423Stream fileStream = new FileStream(path, FileMode.Open, FileAccess.Read, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1533internal static void ReadFromStream(this Stream stream, byte[] content, int startIndex, int length)
MSBuildTaskHost (20)
FileUtilities.cs (3)
1409Stream fileStream = new FileStream(path, mode, FileAccess.Write, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1423Stream fileStream = new FileStream(path, FileMode.Open, FileAccess.Read, FileShare.Read, DefaultFileStreamBufferSize, FileOptions.SequentialScan);
1533internal static void ReadFromStream(this Stream stream, byte[] content, int startIndex, int length)
mscorlib (1)
netstandard (1)
PresentationBuildTasks (24)
src\Microsoft.DotNet.Wpf\src\PresentationFramework\System\Windows\Markup\XamlParser.cs (1)
70Stream xamlStream,
PresentationCore (240)
MS\Internal\Ink\InkSerializedFormat\CustomAttributeSerializer.cs (7)
44internal static void EncodeToStream(ExtendedProperty attribute, Stream stream)
76internal static void EncodeAttribute(Guid guid, object value, VarEnum type, Stream stream)
306internal static uint EncodeAsISF(Guid id, byte[] data, Stream strm, GuidList guidList, byte compressionAlgorithm, bool fTag)
405internal static uint DecodeAsISF(Stream stream, uint cbSize, GuidList guidList, KnownTagCache.KnownTagIndex tag, ref Guid guid, out object data)
504internal static object DecodeAttribute(Guid guid, Stream stream)
522internal static object DecodeAttribute(Guid guid, Stream memStream, out VarEnum type)
720internal static uint EncodeAsISF(ExtendedPropertyCollection attributes, Stream stream, GuidList guidList, byte compressionAlgorithm, bool fTag)
MS\Internal\Ink\InkSerializedFormat\DrawingAttributeSerializer.cs (8)
112internal static uint DecodeAsISF(Stream stream, GuidList guidList, uint maximumStreamSize, DrawingAttributes da)
447internal static uint EncodeAsISF(DrawingAttributes da, Stream stream, GuidList guidList, byte compressionAlgorithm, bool fTag)
473private static void PersistDrawingFlags(DrawingAttributes da, Stream stream, GuidList guidList, ref uint cbData, ref BinaryWriter bw)
491private static void PersistColorAndTransparency(DrawingAttributes da, Stream stream, GuidList guidList, ref uint cbData, ref BinaryWriter bw)
524private static void PersistRasterOperation(DrawingAttributes da, Stream stream, GuidList guidList, ref uint cbData, ref BinaryWriter bw)
556private static void PersistExtendedProperties(DrawingAttributes da, Stream stream, GuidList guidList, ref uint cbData, ref BinaryWriter bw, byte compressionAlgorithm, bool fTag)
593private static void PersistStylusTip(DrawingAttributes da, Stream stream, GuidList guidList, ref uint cbData, ref BinaryWriter bw)
620private static void PersistWidthHeight(DrawingAttributes da, Stream stream, GuidList guidList, ref uint cbData, ref BinaryWriter bw)
MS\Internal\Ink\InkSerializedFormat\InkSerializer.cs (25)
66internal void DecodeISF(Stream inkData)
196internal uint LoadStrokeIds(Stream isfStream, uint cbSize)
234private bool IsGIFData(Stream inkdata)
251private void ExamineStreamHeader(Stream inkdata, out bool fBase64, out bool fGif, out uint cbData)
292private void DecodeRawISF(Stream inputStream)
813private uint LoadDrawAttrsTable(Stream strm, GuidList guidList, uint cbSize)
874private uint DecodeStrokeDescriptor(Stream strm, uint cbSize, out StrokeDescriptor descr)
954private uint DecodeStrokeDescriptorBlock(Stream strm, uint cbSize)
978private uint DecodeStrokeDescriptorTable(Stream strm, uint cbSize)
1030private uint DecodeMetricTable(Stream strm, uint cbSize)
1080private uint DecodeMetricBlock(Stream strm, uint cbSize, out MetricBlock block)
1149private uint DecodeTransformTable(Stream strm, uint cbSize, bool useDoubles)
1205internal static uint ReliableRead(Stream stream, byte[] buffer, uint requestedCount)
1241private uint DecodeTransformBlock(Stream strm, KnownTagCache.KnownTagIndex tag, uint cbSize, bool useDoubles, out TransformDescriptor xform)
1323private uint DecodeInkSpaceRectangle(Stream strm, uint cbSize)
1673internal void EncodeISF(Stream outputStream)
1868private void StoreStrokeData(Stream localStream, GuidList guidList, ref uint cumulativeEncodedSize, ref uint localEncodedSize)
1993internal static uint SaveStrokeIds(StrokeCollection strokes, Stream strm, bool forceSave)
2086private bool IsBase64Data(Stream data)
2191private uint SerializePacketDescrTable(Stream strm)
2247private uint SerializeMetricTable(Stream strm)
2295private uint EncodeStrokeDescriptor(Stream strm, StrokeDescriptor strd)
2316private uint SerializeTransformTable(Stream strm)
2390private uint EncodeTransformDescriptor(Stream strm, TransformDescriptor xform, bool useDoubles)
2443private uint SerializeDrawingAttrsTable(Stream stream, GuidList guidList)
System\Windows\BinaryFormat\BinaryFormatWriter.cs (27)
50public static void WriteString(Stream stream, string value)
59public static void WriteDecimal(Stream stream, decimal value)
82public static void WriteDateTime(Stream stream, DateTime value)
101public static void WriteTimeSpan(Stream stream, TimeSpan value)
113public static void WriteNativeInt(Stream stream, nint value)
125public static void WriteNativeUInt(Stream stream, nuint value)
137public static void WritePointF(Stream stream, PointF value)
154public static void WriteRectangleF(Stream stream, RectangleF value)
176public static bool TryWritePrimitive(Stream stream, object primitive)
185public static void WritePrimitive(Stream stream, object primitive)
233public static void WriteStringList(Stream stream, List<string> list)
261public static void WritePrimitiveList<T>(Stream stream, List<T> list)
295public static bool TryWritePrimitiveList(Stream stream, IList list)
305static bool Write(Stream stream, IList list)
363public static bool TryWriteArrayList(Stream stream, ArrayList list)
367static bool Write(Stream stream, ArrayList list)
392public static bool TryWriteArray(Stream stream, Array array)
396static bool Write(Stream stream, Array array)
427public static bool TryWriteHashtable(Stream stream, Hashtable hashtable)
441public static void WritePrimitiveHashtable(Stream stream, Hashtable hashtable)
498public static void WriteNotSupportedException(Stream stream, NotSupportedException exception)
535public static bool TryWriteFrameworkObject(Stream stream, object value)
539static bool Write(Stream stream, object value)
589public static bool TryWrite<T>(Action<Stream, T> action, Stream stream, T value)
599public static bool TryWrite<T>(Func<Stream, T, bool> func, Stream stream, T value)
PresentationCore.Tests (1)
PresentationFramework (181)
MS\Internal\AppModel\AppModelKnownContentFactory.cs (6)
28internal static object BamlConverter(Stream stream, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter)
33internal static object BamlConverterCore(Stream stream, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter, bool isUnsafe)
68internal static object XamlConverter(Stream stream, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter)
73internal static object XamlConverterCore(Stream stream, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter, bool isUnsafe)
130internal static object HtmlXappConverter(Stream stream, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter)
135internal static object HtmlXappConverterCore(Stream stream, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter, bool isUnsafe)
MS\Internal\AppModel\MimeObjectFactory.cs (5)
16internal delegate object StreamToObjectFactoryDelegate(Stream s, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter);
17internal delegate object StreamToObjectFactoryDelegateCore(Stream s, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter, bool isUnsafe);
30internal static object GetObjectAndCloseStream(Stream s, ContentType contentType, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter)
35internal static object GetObjectAndCloseStreamCore(Stream s, ContentType contentType, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter, bool isUnsafe)
60StreamToObjectFactoryDelegateCore methodCore = new StreamToObjectFactoryDelegateCore((Stream s, Uri baseUri, bool canUseTopLevelBrowser, bool sandboxExternalContent, bool allowAsync, bool isJournalNavigation, out XamlReader asyncObjectConverter, bool isUnsafe) => method(s, baseUri, canUseTopLevelBrowser, sandboxExternalContent, allowAsync, isJournalNavigation, out asyncObjectConverter));
System\Windows\Documents\XPSS0ValidatingLoader.cs (3)
31internal object Load(Stream stream, Uri parentUri, ParserContext pc, ContentType mimeType)
36internal void Validate(Stream stream, Uri parentUri, ParserContext pc, ContentType mimeType, string rootElement)
51private object Load(Stream stream, Uri parentUri, ParserContext pc, ContentType mimeType, string rootElement)
PresentationFramework-SystemDrawing (4)
PresentationUI (89)
RazorBuildWebSite (1)
ReachFramework (45)
Serialization\XpsImageSerializationService.cs (1)
193Stream
Replay (6)
RequestDecompressionSample (2)
ResponseCompressionSample (2)
Roslyn.Test.PdbUtilities (25)
Reader\PdbValidation.cs (9)
271Stream peStream,
272Stream pdbStream,
294Stream peStream,
295Stream pdbStream,
319Stream peStreamOriginal,
320Stream pdbStreamOriginal,
540public static unsafe byte[] GetSourceLinkData(Stream pdbStream)
563public static void ValidateDebugDirectory(Stream peStream, Stream portablePdbStreamOpt, string pdbPath, HashAlgorithmName hashAlgorithm, bool hasEmbeddedPdb, bool isDeterministic)
Roslyn.VisualStudio.Next.UnitTests (6)
Sample (1)
ScenarioTests.Common.Tests (17)
Security.TransportSecurity.IntegrationTests (14)
SemanticSearch.BuildTask (4)
ServerComparison.FunctionalTests (1)
Shared (10)
ServerSentEvents\SseFormatter.cs (3)
30public static Task WriteAsync(IAsyncEnumerable<SseItem<string>> source, Stream destination, CancellationToken cancellationToken = default)
54public static Task WriteAsync<T>(IAsyncEnumerable<SseItem<T>> source, Stream destination, Action<SseItem<T>, IBufferWriter<byte>> itemFormatter, CancellationToken cancellationToken = default)
74private static async Task WriteAsyncCore<T>(IAsyncEnumerable<SseItem<T>> source, Stream destination, Action<SseItem<T>, IBufferWriter<byte>> itemFormatter, CancellationToken cancellationToken)
SimpleWebSiteWithWebApplicationBuilder (1)
SocialWeather (8)
Sockets.BindTests (3)
Sockets.FunctionalTests (16)
src\Servers\Kestrel\shared\test\StreamExtensions.cs (4)
15public static async Task<int> FillBufferUntilEndAsync(this Stream stream, byte[] buffer, CancellationToken cancellationToken = default)
34public static async Task<int> FillEntireBufferAsync(this Stream stream, byte[] buffer, CancellationToken cancellationToken = default)
49public static async Task<byte[]> ReadAtLeastLengthAsync(this Stream stream, int length, int bufferLength = 1024, bool allowEmpty = false, CancellationToken cancellationToken = default)
76public static async Task<byte[]> ReadUntilEndAsync(this Stream stream, int bufferLength = 1024, CancellationToken cancellationToken = default)
Stress.ApiService (1)
System.ComponentModel.TypeConverter (11)
System.Configuration.ConfigurationManager (40)
System.Console (13)
System.Data.Common (37)
System\Data\DataSet.cs (14)
1618public void InferXmlSchema(Stream? stream, string[]? nsArray)
1867/// Reads the XML schema from the specified <see cref='System.IO.Stream'/> into the
1872public void ReadXmlSchema(Stream? stream)
1916/// <summary>Writes the <see cref='DataSet'/> structure as an XML schema to using the specified <see cref='Stream'/> object.</summary>
1917/// <param name="stream">A <see cref='Stream'/> object used to write to a file.</param>
1920public void WriteXmlSchema(Stream? stream) => WriteXmlSchema(stream, SchemaFormat.Public, null);
1922/// <summary>Writes the <see cref='DataSet'/> structure as an XML schema to using the specified <see cref='Stream'/> object.</summary>
1923/// <param name="stream">A <see cref='Stream'/> object used to write to a file.</param>
1927public void WriteXmlSchema(Stream? stream, Converter<Type, string> multipleTargetConverter)
2004private void WriteXmlSchema(Stream? stream, SchemaFormat schemaFormat, Converter<Type, string>? multipleTargetConverter)
2345public XmlReadMode ReadXml(Stream? stream)
2838public XmlReadMode ReadXml(Stream? stream, XmlReadMode mode)
2896public void WriteXml(Stream? stream) => WriteXml(stream, XmlWriteMode.IgnoreSchema);
2915public void WriteXml(Stream? stream, XmlWriteMode mode)
System\Data\DataTable.cs (8)
5316public void WriteXml(Stream? stream) => WriteXml(stream, XmlWriteMode.IgnoreSchema, false);
5320public void WriteXml(Stream? stream, bool writeHierarchy) => WriteXml(stream, XmlWriteMode.IgnoreSchema, writeHierarchy);
5348public void WriteXml(Stream? stream, XmlWriteMode mode) => WriteXml(stream, mode, false);
5352public void WriteXml(Stream? stream, XmlWriteMode mode, bool writeHierarchy)
5488public void WriteXmlSchema(Stream? stream) => WriteXmlSchema(stream, false);
5492public void WriteXmlSchema(Stream? stream, bool writeHierarchy)
5642public XmlReadMode ReadXml(Stream? stream)
6432public void ReadXmlSchema(Stream? stream)
System\Data\SQLTypes\SqlXml.cs (8)
19private static readonly Func<Stream, XmlReaderSettings, XmlParserContext?, XmlReader> s_sqlReaderDelegate = CreateSqlReaderDelegate();
26private Stream? _stream;
56public SqlXml(Stream? value)
96internal static XmlReader CreateSqlXmlReader(Stream stream, bool closeInput = false, bool throwTargetInvocationExceptions = false)
118private static Func<Stream, XmlReaderSettings, XmlParserContext?, XmlReader> CreateSqlReaderDelegate()
122return CreateSqlReaderMethodInfo.CreateDelegate<Func<Stream, XmlReaderSettings, XmlParserContext?, XmlReader>>();
272private readonly Stream _stream;
280internal SqlXmlStreamWrapper(Stream stream)
System.Data.Odbc (3)
System.Diagnostics.Process (4)
System.Diagnostics.StackTrace (2)
System.Diagnostics.TextWriterTraceListener (7)
System.Drawing.Common (24)
Special\NotSupported.cs (24)
22public Bitmap(System.IO.Stream stream) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
23public Bitmap(System.IO.Stream stream, bool useIcm) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
701public Icon(System.IO.Stream stream) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
702public Icon(System.IO.Stream stream, System.Drawing.Size size) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
703public Icon(System.IO.Stream stream, int width, int height) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
720public void Save(System.IO.Stream outputStream) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
782public static System.Drawing.Image FromStream(System.IO.Stream stream) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
783public static System.Drawing.Image FromStream(System.IO.Stream stream, bool useEmbeddedColorManagement) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
784public static System.Drawing.Image FromStream(System.IO.Stream stream, bool useEmbeddedColorManagement, bool validateImageData) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
796public void Save(System.IO.Stream stream, System.Drawing.Imaging.ImageCodecInfo encoder, System.Drawing.Imaging.EncoderParameters? encoderParams) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
797public void Save(System.IO.Stream stream, System.Drawing.Imaging.ImageFormat format) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2548public Metafile(System.IO.Stream stream) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2549public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2550public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc, System.Drawing.Imaging.EmfType type) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2551public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc, System.Drawing.Imaging.EmfType type, string? description) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2552public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc, System.Drawing.Rectangle frameRect) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2553public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc, System.Drawing.Rectangle frameRect, System.Drawing.Imaging.MetafileFrameUnit frameUnit) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2554public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc, System.Drawing.Rectangle frameRect, System.Drawing.Imaging.MetafileFrameUnit frameUnit, System.Drawing.Imaging.EmfType type) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2555public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc, System.Drawing.Rectangle frameRect, System.Drawing.Imaging.MetafileFrameUnit frameUnit, System.Drawing.Imaging.EmfType type, string? description) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2556public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc, System.Drawing.RectangleF frameRect) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2557public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc, System.Drawing.RectangleF frameRect, System.Drawing.Imaging.MetafileFrameUnit frameUnit) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2558public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc, System.Drawing.RectangleF frameRect, System.Drawing.Imaging.MetafileFrameUnit frameUnit, System.Drawing.Imaging.EmfType type) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2559public Metafile(System.IO.Stream stream, System.IntPtr referenceHdc, System.Drawing.RectangleF frameRect, System.Drawing.Imaging.MetafileFrameUnit frameUnit, System.Drawing.Imaging.EmfType type, string? description) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
2578public static System.Drawing.Imaging.MetafileHeader GetMetafileHeader(System.IO.Stream stream) { throw new System.PlatformNotSupportedException(System.SR.SystemDrawingCommon_PlatformNotSupported); }
System.Drawing.Common.Tests (21)
System\Drawing\BitmapTests.cs (11)
120using Stream stream = File.OpenRead(Helpers.GetTestBitmapPath(filename));
134using Stream stream = File.OpenRead(Helpers.GetTestBitmapPath(filename));
146AssertExtensions.Throws<ArgumentNullException, ArgumentException>("stream", null, () => new Bitmap((Stream)null));
147AssertExtensions.Throws<ArgumentNullException, ArgumentException>("stream", null, () => new Bitmap((Stream)null, false));
740using Stream wmfStream = File.OpenRead(Helpers.GetTestBitmapPath("gdiwmfboundariesbug.wmf"));
744using Stream expectedPngStream = File.OpenRead(Helpers.GetTestBitmapPath("gdiwmfboundariesbug-output.png"));
747using Stream outputPngStream = File.OpenRead(output);
1587using Stream backingStream = new MemoryStream();
1588using Stream restrictiveStream = new TestStream(backingStream, canRead, canSeek);
1693private readonly Stream _stream;
1697public TestStream(Stream stream, bool canRead = true, bool canSeek = true)
System\Drawing\IconTests.cs (3)
145AssertExtensions.Throws<ArgumentNullException, ArgumentException>("stream", null, () => new Icon((Stream)null));
146AssertExtensions.Throws<ArgumentNullException, ArgumentException>("stream", null, () => new Icon((Stream)null, 32, 32));
147AssertExtensions.Throws<ArgumentNullException, ArgumentException>("stream", null, () => new Icon((Stream)null, new Size(32, 32)));
System\Drawing\Imaging\MetafileTests.cs (6)
101AssertExtensions.Throws<ArgumentNullException, ArgumentException>("stream", null, () => new Metafile((Stream)null));
827Assert.Throws<ArgumentNullException>(() => new Metafile((Stream)null, referenceHdc, _rectangleF));
828Assert.Throws<ArgumentNullException>(() => new Metafile((Stream)null, referenceHdc, _rectangleF, MetafileFrameUnit.GdiCompatible));
830new Metafile((Stream)null, referenceHdc, _rectangleF, MetafileFrameUnit.GdiCompatible, EmfType.EmfOnly));
832new Metafile((Stream)null, referenceHdc, _rectangleF, MetafileFrameUnit.GdiCompatible, EmfType.EmfOnly, "description"));
875Assert.Throws<ArgumentNullException>(() => Metafile.GetMetafileHeader((Stream)null));
System.Formats.Nrbf (6)
System.Formats.Tar (70)
System.IO (1)
System.IO.Compression (89)
System\IO\Compression\DeflateZLib\DeflateStream.cs (18)
18private Stream _stream;
27internal DeflateStream(Stream stream, CompressionMode mode, long uncompressedSize) : this(stream, mode, leaveOpen: false, ZLibNative.Deflate_DefaultWindowBits, uncompressedSize)
31public DeflateStream(Stream stream, CompressionMode mode) : this(stream, mode, leaveOpen: false)
35public DeflateStream(Stream stream, CompressionMode mode, bool leaveOpen) : this(stream, mode, leaveOpen, ZLibNative.Deflate_DefaultWindowBits)
40public DeflateStream(Stream stream, CompressionLevel compressionLevel) : this(stream, compressionLevel, leaveOpen: false)
45public DeflateStream(Stream stream, CompressionLevel compressionLevel, bool leaveOpen) : this(stream, compressionLevel, leaveOpen, ZLibNative.Deflate_DefaultWindowBits)
56public DeflateStream(Stream stream, ZLibCompressionOptions compressionOptions, bool leaveOpen = false) : this(stream, compressionOptions, leaveOpen, ZLibNative.Deflate_DefaultWindowBits)
60internal DeflateStream(Stream stream, ZLibCompressionOptions compressionOptions, bool leaveOpen, int windowBits)
72internal DeflateStream(Stream stream, CompressionMode mode, bool leaveOpen, int windowBits, long uncompressedSize = -1)
100internal DeflateStream(Stream stream, CompressionLevel compressionLevel, bool leaveOpen, int windowBits)
111internal void InitializeDeflater(Stream stream, ZLibNative.CompressionLevel compressionLevel, CompressionStrategy strategy, bool leaveOpen, int windowBits)
156public Stream BaseStream => _stream;
766Stream stream = _stream;
879public override void CopyTo(Stream destination, int bufferSize)
889public override Task CopyToAsync(Stream destination, int bufferSize, CancellationToken cancellationToken)
910private readonly Stream _destination;
914public CopyToStream(DeflateStream deflateStream, Stream destination, int bufferSize) :
919public CopyToStream(DeflateStream deflateStream, Stream destination, int bufferSize, CancellationToken cancellationToken)
System\IO\Compression\GZipStream.cs (8)
15public GZipStream(Stream stream, CompressionMode mode) : this(stream, mode, leaveOpen: false)
19public GZipStream(Stream stream, CompressionMode mode, bool leaveOpen)
25public GZipStream(Stream stream, CompressionLevel compressionLevel) : this(stream, compressionLevel, leaveOpen: false)
30public GZipStream(Stream stream, CompressionLevel compressionLevel, bool leaveOpen)
42public GZipStream(Stream stream, ZLibCompressionOptions compressionOptions, bool leaveOpen = false)
158public override void CopyTo(Stream destination, int bufferSize)
197public Stream BaseStream => _deflateStream?.BaseStream!;
249public override Task CopyToAsync(Stream destination, int bufferSize, CancellationToken cancellationToken)
System\IO\Compression\ZipArchive.cs (9)
18private readonly Stream _archiveStream;
30private readonly Stream? _backingStream;
46public ZipArchive(Stream stream) : this(stream, ZipArchiveMode.Read, leaveOpen: false, entryNameEncoding: null) { }
57public ZipArchive(Stream stream, ZipArchiveMode mode) : this(stream, mode, leaveOpen: false, entryNameEncoding: null) { }
69public ZipArchive(Stream stream, ZipArchiveMode mode, bool leaveOpen) : this(stream, mode, leaveOpen, entryNameEncoding: null) { }
121public ZipArchive(Stream stream, ZipArchiveMode mode, bool leaveOpen, Encoding? entryNameEncoding)
126Stream? extraTempStream = null;
216/// The comment encoding is determined by the <c>entryNameEncoding</c> parameter of the <see cref="ZipArchive(Stream,ZipArchiveMode,bool,Encoding?)"/> constructor.
357internal Stream ArchiveStream => _archiveStream;
System\IO\Compression\ZipArchiveEntry.cs (13)
40private Stream? _outstandingWriteStream;
203///The comment encoding is determined by the <c>entryNameEncoding</c> parameter of the <see cref="ZipArchive(Stream,ZipArchiveMode,bool,Encoding?)"/> constructor.
343public Stream Open()
419using (Stream decompressor = OpenInReadMode(false))
668private CheckSumAndSizeWriteStream GetDataCompressor(Stream backingStream, bool leaveBackingStreamOpen, EventHandler? onClose)
679Stream compressorStream;
700(long initialPosition, long currentPosition, uint checkSum, Stream backing, ZipArchiveEntry thisRef, EventHandler? closeHandler) =>
711private Stream GetDataDecompressor(Stream compressedStreamToRead)
713Stream? uncompressedStream;
735private Stream OpenInReadMode(bool checkOpenable)
740Stream compressedStream = new SubReadStream(_archive.ArchiveStream, OffsetOfCompressedData, _compressedSize);
1041using (Stream entryWriter = new DirectToArchiveWriterStream(
System\IO\Compression\ZipBlocks.cs (12)
26public void WriteBlock(Stream stream)
88public static void WriteAllBlocks(List<ZipGenericExtraField> fields, Stream stream)
340public void WriteBlock(Stream stream)
389public static bool TryReadBlock(Stream stream, out Zip64EndOfCentralDirectoryLocator zip64EOCDLocator)
414public static void WriteBlock(Stream stream, long zip64EOCDRecordStart)
449public static bool TryReadBlock(Stream stream, out Zip64EndOfCentralDirectoryRecord zip64EOCDRecord)
480public static void WriteBlock(Stream stream, long numberOfEntries, long startOfCentralDirectory, long sizeOfCentralDirectory)
514public static List<ZipGenericExtraField> GetExtraFields(Stream stream)
553public static bool TrySkipBlock(Stream stream)
626public static bool TryReadBlock(ReadOnlySpan<byte> buffer, Stream furtherReads, bool saveExtraFieldsAndComments, out int bytesRead, out ZipCentralDirectoryFileHeader header)
771public static void WriteBlock(Stream stream, long numberOfEntries, long startOfCentralDirectory, long sizeOfCentralDirectory, byte[] archiveComment)
807public static bool TryReadBlock(Stream stream, out ZipEndOfCentralDirectoryBlock eocdBlock)
System\IO\Compression\ZipCustomStreams.cs (12)
13private readonly Stream _baseStream;
23internal WrappedStream(Stream baseStream, bool closeBaseStream)
26private WrappedStream(Stream baseStream, bool closeBaseStream, ZipArchiveEntry? entry, Action<ZipArchiveEntry?>? onClosed)
35internal WrappedStream(Stream baseStream, ZipArchiveEntry entry, Action<ZipArchiveEntry?>? onClosed)
226private readonly Stream _superStream;
230public SubReadStream(Stream superStream, long startPosition, long maxLength)
405private readonly Stream _baseStream;
406private readonly Stream _baseBaseStream;
422private readonly Action<long, long, uint, Stream, ZipArchiveEntry, EventHandler?> _saveCrcAndSizes;
431public CheckSumAndSizeWriteStream(Stream baseStream, Stream baseBaseStream, bool leaveOpenOnClose,
433Action<long, long, uint, Stream, ZipArchiveEntry, EventHandler?> saveCrcAndSizes)
System\IO\Compression\ZLibStream.cs (10)
19public ZLibStream(Stream stream, CompressionMode mode) : this(stream, mode, leaveOpen: false)
27public ZLibStream(Stream stream, CompressionMode mode, bool leaveOpen)
35public ZLibStream(Stream stream, CompressionLevel compressionLevel) : this(stream, compressionLevel, leaveOpen: false)
43public ZLibStream(Stream stream, CompressionLevel compressionLevel, bool leaveOpen)
55public ZLibStream(Stream stream, ZLibCompressionOptions compressionOptions, bool leaveOpen = false)
239public override void CopyTo(Stream destination, int bufferSize)
250public override Task CopyToAsync(Stream destination, int bufferSize, CancellationToken cancellationToken)
256/// <summary>Releases all resources used by the <see cref="Stream"/>.</summary>
274/// <summary>Asynchronously releases all resources used by the <see cref="Stream"/>.</summary>
289public Stream BaseStream => _deflateStream?.BaseStream!;
System.IO.Compression.Brotli (11)
System\IO\Compression\enc\BrotliStream.Compress.cs (5)
20public BrotliStream(Stream stream, CompressionLevel compressionLevel) : this(stream, compressionLevel, leaveOpen: false) { }
27public BrotliStream(Stream stream, CompressionLevel compressionLevel, bool leaveOpen) : this(stream, CompressionMode.Compress, leaveOpen)
39public BrotliStream(Stream stream, BrotliCompressionOptions compressionOptions, bool leaveOpen = false) : this(stream, CompressionMode.Compress, leaveOpen)
100/// <summary>Begins an asynchronous write operation. (Consider using the <see cref="System.IO.Stream.WriteAsync(byte[],int,int)" /> method instead.)</summary>
115/// <summary>Handles the end of an asynchronous write operation. (Consider using the <see cref="System.IO.Stream.WriteAsync(byte[],int,int)" /> method instead.)</summary>
System.IO.Compression.ZipFile (11)
System\IO\Compression\ZipFile.Create.cs (5)
360/// If you want to include the base directory or specify a compression level, call the <see cref="CreateFromDirectory(string, Stream, CompressionLevel, bool)"/> method overload.
374public static void CreateFromDirectory(string sourceDirectoryName, Stream destination) =>
401public static void CreateFromDirectory(string sourceDirectoryName, Stream destination, CompressionLevel compressionLevel, bool includeBaseDirectory) =>
429public static void CreateFromDirectory(string sourceDirectoryName, Stream destination,
449private static void DoCreateFromDirectory(string sourceDirectoryName, Stream destination,
System.IO.Hashing (4)
System.IO.IsolatedStorage (1)
System.IO.Packaging (44)
System.IO.Pipelines (25)
System.IO.Ports (1)
System.Memory.Data (9)
System.Net.Http (225)
System\Net\Http\HttpContent.cs (37)
199public Stream ReadAsStream() =>
202public Stream ReadAsStream(CancellationToken cancellationToken)
212Stream s = IsBuffered ?
218else if (_contentReadStream is Stream stream) // have a Stream
229public Task<Stream> ReadAsStreamAsync() =>
232public Task<Stream> ReadAsStreamAsync(CancellationToken cancellationToken)
242Task<Stream> t = IsBuffered ?
243Task.FromResult<Stream>(CreateMemoryStreamFromBufferedContent()) :
248else if (_contentReadStream is Task<Stream> t) // have a Task<Stream>
254Debug.Assert(_contentReadStream is Stream, $"Expected a Stream, got ${_contentReadStream}");
255Task<Stream> ts = Task.FromResult((Stream)_contentReadStream);
261internal Stream? TryReadAsStream()
271Stream? s = IsBuffered ?
277else if (_contentReadStream is Stream s) // have a Stream
283Debug.Assert(_contentReadStream is Task<Stream>, $"Expected a Task<Stream>, got ${_contentReadStream}");
284Task<Stream> t = (Task<Stream>)_contentReadStream;
289protected abstract Task SerializeToStreamAsync(Stream stream, TransportContext? context);
294protected virtual void SerializeToStream(Stream stream, TransportContext? context, CancellationToken cancellationToken)
299protected virtual Task SerializeToStreamAsync(Stream stream, TransportContext? context, CancellationToken cancellationToken) =>
310public void CopyTo(Stream stream, TransportContext? context, CancellationToken cancellationToken)
331public Task CopyToAsync(Stream stream) =>
334public Task CopyToAsync(Stream stream, CancellationToken cancellationToken) =>
337public Task CopyToAsync(Stream stream, TransportContext? context) =>
340public Task CopyToAsync(Stream stream, TransportContext? context, CancellationToken cancellationToken)
366internal ValueTask InternalCopyToAsync(Stream stream, TransportContext? context, CancellationToken cancellationToken)
447/// After content is serialized to a memory buffer, calls to one of the <see cref="CopyToAsync(Stream)"/> methods will copy the content of the memory buffer to the target stream.
462/// After content is serialized to a memory buffer, calls to one of the <see cref="CopyToAsync(Stream)"/> methods will copy the content of the memory buffer to the target stream.
531protected virtual Stream CreateContentReadStream(CancellationToken cancellationToken)
537protected virtual Task<Stream> CreateContentReadStreamAsync()
542return WaitAndReturnAsync(LoadIntoBufferAsync(), this, static s => (Stream)s.CreateMemoryStreamFromBufferedContent());
545protected virtual Task<Stream> CreateContentReadStreamAsync(CancellationToken cancellationToken)
555internal virtual Stream? TryCreateContentReadStream() => null;
636Stream? s = _contentReadStream as Stream ??
637(_contentReadStream is Task<Stream> t && t.Status == TaskStatus.RanToCompletion ? t.Result : null);
System\Net\Http\MultipartContent.cs (22)
156protected override void SerializeToStream(Stream stream, TransportContext? context, CancellationToken cancellationToken)
191protected override Task SerializeToStreamAsync(Stream stream, TransportContext? context) =>
194protected override Task SerializeToStreamAsync(Stream stream, TransportContext? context, CancellationToken cancellationToken) =>
200private protected async Task SerializeToStreamAsyncCore(Stream stream, TransportContext? context, CancellationToken cancellationToken)
233protected override Stream CreateContentReadStream(CancellationToken cancellationToken)
235ValueTask<Stream> task = CreateContentReadStreamAsyncCore(async: false, cancellationToken);
240protected override Task<Stream> CreateContentReadStreamAsync() =>
243protected override Task<Stream> CreateContentReadStreamAsync(CancellationToken cancellationToken) =>
249private async ValueTask<Stream> CreateContentReadStreamAsyncCore(bool async, CancellationToken cancellationToken)
253var streams = new Stream[2 + (_nestedContent.Count * 2)];
267Stream readStream;
306private void SerializeHeadersToStream(Stream stream, HttpContent content, bool writeDivider)
337private static ValueTask EncodeStringToStreamAsync(Stream stream, string input, CancellationToken cancellationToken)
413private readonly Stream[] _streams;
417private Stream? _current;
420internal ContentReadStream(Stream[] streams)
424foreach (Stream stream in streams)
434foreach (Stream s in _streams)
443foreach (Stream s in _streams)
575Stream curStream = _streams[i];
639private static void WriteToStream(Stream stream, string content) =>
642private static void WriteToStream(Stream stream, string content, Encoding encoding)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (14)
568private async ValueTask<(Stream, TransportContext?, Activity?, IPEndPoint?)> ConnectAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken)
570Stream? stream = null;
607if (stream is HttpContentStream contentStream && contentStream._connection?._stream is Stream innerStream)
657static IPEndPoint? GetRemoteEndPoint(Stream stream) => (stream as NetworkStream)?.Socket?.RemoteEndPoint as IPEndPoint;
660private async ValueTask<Stream> ConnectToTcpHostAsync(string host, int port, HttpRequestMessage initialRequest, bool async, CancellationToken cancellationToken)
665Stream? stream = null;
671ValueTask<Stream> streamTask = Settings._connectCallback(new SocketsHttpConnectionContext(endPoint, initialRequest), cancellationToken);
738private async ValueTask<Stream> ApplyPlaintextFilterAsync(bool async, Stream stream, Version httpVersion, HttpRequestMessage request, CancellationToken cancellationToken)
745Stream newStream;
748ValueTask<Stream> streamTask = Settings._plaintextStreamFilter(new SocketsHttpPlaintextStreamFilterContext(stream, httpVersion, request), cancellationToken);
781private async ValueTask<Stream> EstablishProxyTunnelAsync(bool async, CancellationToken cancellationToken)
811private async ValueTask<Stream> EstablishSocksTunnel(HttpRequestMessage request, bool async, CancellationToken cancellationToken)
815Stream stream = await ConnectToTcpHostAsync(_proxyUri.IdnHost, _proxyUri.Port, request, async, cancellationToken).ConfigureAwait(false);
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http1.cs (3)
296(Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint) = await ConnectAsync(request, async, cancellationToken).ConfigureAwait(false);
300private async ValueTask<HttpConnection> ConstructHttp11ConnectionAsync(bool async, Stream stream, TransportContext? transportContext, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)
302Stream newStream = await ApplyPlaintextFilterAsync(async, stream, HttpVersion.Version11, request, cancellationToken).ConfigureAwait(false);
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http2.cs (3)
187(Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint) = await ConnectAsync(queueItem.Request, true, cts.Token).ConfigureAwait(false);
246private async ValueTask<Http2Connection> ConstructHttp2ConnectionAsync(Stream stream, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)
289private async Task HandleHttp11Downgrade(HttpRequestMessage request, Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\DecompressionHandler.cs (29)
135protected abstract Stream GetDecompressedStream(Stream originalStream);
137protected override void SerializeToStream(Stream stream, TransportContext? context, CancellationToken cancellationToken)
139using Stream decompressedStream = CreateContentReadStream(cancellationToken);
143protected override Task SerializeToStreamAsync(Stream stream, TransportContext? context) =>
146protected override async Task SerializeToStreamAsync(Stream stream, TransportContext? context, CancellationToken cancellationToken)
148using (Stream decompressedStream = TryCreateContentReadStream() ?? await CreateContentReadStreamAsync(cancellationToken).ConfigureAwait(false))
154protected override Stream CreateContentReadStream(CancellationToken cancellationToken)
156ValueTask<Stream> task = CreateContentReadStreamAsyncCore(async: false, cancellationToken);
161protected override Task<Stream> CreateContentReadStreamAsync(CancellationToken cancellationToken) =>
164private async ValueTask<Stream> CreateContentReadStreamAsyncCore(bool async, CancellationToken cancellationToken)
173Stream originalStream;
185internal override Stream? TryCreateContentReadStream()
187Stream? originalStream = _originalContent.TryReadAsStream();
215protected override Stream GetDecompressedStream(Stream originalStream) =>
225protected override Stream GetDecompressedStream(Stream originalStream) =>
238private Stream? _decompressionStream;
240public ZLibOrDeflateStream(Stream stream) => _stream = new PeekFirstByteReadStream(stream);
289public override Task CopyToAsync(Stream destination, int bufferSize, CancellationToken cancellationToken)
293async Task Core(Stream destination, int bufferSize, CancellationToken cancellationToken)
305private static Stream CreateDecompressionStream(int firstByte, Stream stream) =>
312private readonly Stream _stream;
316public PeekFirstByteReadStream(Stream stream) => _stream = stream;
401public override async Task CopyToAsync(Stream destination, int bufferSize, CancellationToken cancellationToken)
431protected override Stream GetDecompressedStream(Stream originalStream) =>
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (6)
1186public void CopyTo(HttpResponseMessage responseMessage, Stream destination, int bufferSize)
1222public async Task CopyToAsync(HttpResponseMessage responseMessage, Stream destination, int bufferSize, CancellationToken cancellationToken)
1527public override void CopyTo(Stream destination, int bufferSize) => throw new NotSupportedException(SR.net_http_content_writeonly_stream);
1529public override Task CopyToAsync(Stream destination, int bufferSize, CancellationToken cancellationToken) => Task.FromException(new NotSupportedException(SR.net_http_content_writeonly_stream));
1622public override void CopyTo(Stream destination, int bufferSize)
1629public override Task CopyToAsync(Stream destination, int bufferSize, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (8)
45internal readonly Stream _stream;
74Stream stream,
779Stream responseStream;
1857private ValueTask CopyFromBufferAsync(Stream destination, bool async, int count, CancellationToken cancellationToken)
1877private Task CopyToUntilEofAsync(Stream destination, bool async, int bufferSize, CancellationToken cancellationToken)
1895private async Task CopyToUntilEofWithExistingBufferedDataAsync(Stream destination, bool async, int bufferSize, CancellationToken cancellationToken)
1913private async Task CopyToContentLengthAsync(Stream destination, bool async, ulong length, int bufferSize, CancellationToken cancellationToken)
2077Stream stream = response.Content.ReadAsStream(cancellationToken);
System\Net\Http\SocketsHttpHandler\SocksHelper.cs (6)
32public static async ValueTask EstablishSocksTunnelAsync(Stream stream, string host, int port, Uri proxyUri, ICredentials? proxyCredentials, bool async, CancellationToken cancellationToken)
34using (cancellationToken.Register(s => ((Stream)s!).Dispose(), stream))
65private static async ValueTask EstablishSocks5TunnelAsync(Stream stream, string host, int port, NetworkCredential? credentials, bool async)
213private static async ValueTask EstablishSocks4TunnelAsync(Stream stream, bool isVersion4a, string host, int port, NetworkCredential? credentials, bool async, CancellationToken cancellationToken)
341private static ValueTask WriteAsync(Stream stream, Memory<byte> buffer, bool async)
354private static async ValueTask ReadToFillAsync(Stream stream, Memory<byte> buffer, bool async)
System.Net.Http.Json (30)
System\Net\Http\Json\HttpClientJsonExtensions.cs (8)
37Func<Stream, TJsonOptions, CancellationToken, ValueTask<TValue?>> deserializeMethod,
78Func<Stream, TJsonOptions, CancellationToken, ValueTask<TValue?>> deserializeMethod,
89using Stream readStream = await GetHttpResponseStreamAsync(client, response, usingResponseHeadersRead, cancellationToken)
115private static ValueTask<Stream> GetHttpResponseStreamAsync(
129ValueTask<Stream> task = HttpContentJsonExtensions.GetContentStreamAsync(response.Content, cancellationToken);
136private static async ValueTask<Stream> GetLengthLimitReadStreamAsync(HttpClient client, ValueTask<Stream> task)
138Stream contentStream = await task.ConfigureAwait(false);
System.Net.HttpListener (13)
System.Net.Mail (53)
System\Net\Mail\Attachment.cs (10)
35protected AttachmentBase(Stream contentStream)
40protected AttachmentBase(Stream contentStream, string? mediaType)
45internal AttachmentBase(Stream contentStream, string? name, string? mediaType)
50protected AttachmentBase(Stream contentStream, ContentType? contentType)
73Stream stream = new FileStream(fileName, FileMode.Open, FileAccess.Read, FileShare.Read);
81Stream stream = new FileStream(fileName, FileMode.Open, FileAccess.Read, FileShare.Read);
185public Stream ContentStream
321public Attachment(Stream contentStream, string? name) :
328public Attachment(Stream contentStream, string? name, string? mediaType) :
335public Attachment(Stream contentStream, ContentType contentType) :
System.Net.Quic (1)
System.Net.Requests (71)
System.Net.Security (29)
System\Net\Security\ReadWriteAdapter.cs (12)
12static abstract ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken);
13static abstract ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken);
14static abstract ValueTask WriteAsync(Stream stream, ReadOnlyMemory<byte> buffer, CancellationToken cancellationToken);
15static abstract Task FlushAsync(Stream stream, CancellationToken cancellationToken);
21public static ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) =>
24public static ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) =>
27public static ValueTask WriteAsync(Stream stream, ReadOnlyMemory<byte> buffer, CancellationToken cancellationToken) =>
30public static Task FlushAsync(Stream stream, CancellationToken cancellationToken) => stream.FlushAsync(cancellationToken);
37public static ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) =>
40public static ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) =>
43public static ValueTask WriteAsync(Stream stream, ReadOnlyMemory<byte> buffer, CancellationToken cancellationToken)
49public static Task FlushAsync(Stream stream, CancellationToken cancellationToken)
System.Net.ServerSentEvents (8)
System\Net\ServerSentEvents\SseFormatter.cs (3)
27public static Task WriteAsync(IAsyncEnumerable<SseItem<string>> source, Stream destination, CancellationToken cancellationToken = default)
51public static Task WriteAsync<T>(IAsyncEnumerable<SseItem<T>> source, Stream destination, Action<SseItem<T>, IBufferWriter<byte>> itemFormatter, CancellationToken cancellationToken = default)
71private static async Task WriteAsyncCore<T>(IAsyncEnumerable<SseItem<T>> source, Stream destination, Action<SseItem<T>, IBufferWriter<byte>> itemFormatter, CancellationToken cancellationToken)
System.Net.WebClient (32)
System\Net\WebClient.cs (28)
358public Stream OpenRead(string address) =>
361public Stream OpenRead(Uri address)
385public Stream OpenWrite(string address) =>
388public Stream OpenWrite(Uri address) =>
391public Stream OpenWrite(string address, string? method) =>
394public Stream OpenWrite(Uri address, string? method)
826private byte[]? DownloadBits(WebRequest request, Stream writeStream)
844using (Stream readStream = response.GetResponseStream())
868WebRequest request, Stream writeStream,
897using (Stream readStream = response.GetResponseStream())
954using (Stream writeStream = request.GetRequestStream())
1021using (Stream writeStream = await request.GetRequestStreamAsync().ConfigureAwait(false))
1203Stream? stream = null;
1560public Task<Stream> OpenReadTaskAsync(string address) =>
1563public Task<Stream> OpenReadTaskAsync(Uri address)
1566var tcs = new TaskCompletionSource<Stream>(address);
1585public Task<Stream> OpenWriteTaskAsync(string address) =>
1588public Task<Stream> OpenWriteTaskAsync(Uri address) =>
1591public Task<Stream> OpenWriteTaskAsync(string address, string? method) =>
1594public Task<Stream> OpenWriteTaskAsync(Uri address, string? method)
1597var tcs = new TaskCompletionSource<Stream>(address);
1852public WebClientWriteStream(Stream stream, WebRequest request, WebClient webClient) : base(stream)
1912private readonly Stream? _result;
1914internal OpenReadCompletedEventArgs(Stream? result, Exception? exception, bool cancelled, object? userToken) : base(exception, cancelled, userToken)
1919public Stream Result
1931private readonly Stream? _result;
1933internal OpenWriteCompletedEventArgs(Stream? result, Exception? exception, bool cancelled, object? userToken) : base(exception, cancelled, userToken)
1938public Stream Result
System.Net.WebSockets (11)
System.Net.WebSockets.Client (1)
System.Private.CoreLib (119)
src\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (23)
16public static readonly Stream Null = new NullStream();
49public void CopyTo(Stream destination) => CopyTo(destination, GetCopyBufferSize());
51public virtual void CopyTo(Stream destination, int bufferSize)
79public Task CopyToAsync(Stream destination) => CopyToAsync(destination, GetCopyBufferSize());
81public Task CopyToAsync(Stream destination, int bufferSize) => CopyToAsync(destination, bufferSize, CancellationToken.None);
83public Task CopyToAsync(Stream destination, CancellationToken cancellationToken) => CopyToAsync(destination, GetCopyBufferSize(), cancellationToken);
85public virtual Task CopyToAsync(Stream destination, int bufferSize, CancellationToken cancellationToken)
100static async Task Core(Stream source, Stream destination, int bufferSize, CancellationToken cancellationToken)
193static state => ((Stream)state!).Flush(), this,
639internal Stream? _stream;
656Stream stream, byte[] buffer, int offset, int count, AsyncCallback? callback) :
928public static Stream Synchronized(Stream stream)
937/// <summary>Validates arguments provided to reading and writing methods on <see cref="Stream"/>.</summary>
979/// <summary>Validates arguments provided to the <see cref="CopyTo(Stream, int)"/> or <see cref="CopyToAsync(Stream, int, CancellationToken)"/> methods.</summary>
980/// <param name="destination">The <see cref="Stream"/> "destination" argument passed to the copy method.</param>
986protected static void ValidateCopyToArguments(Stream destination, int bufferSize)
1014public override void CopyTo(Stream destination, int bufferSize) { }
1016public override Task CopyToAsync(Stream destination, int bufferSize, CancellationToken cancellationToken) =>
1085private readonly Stream _stream;
1087internal SyncStream(Stream stream) => _stream = stream;
src\libraries\System.Private.CoreLib\src\System\IO\StreamReader.cs (13)
31private readonly Stream _stream;
100_stream = Stream.Null;
104public StreamReader(Stream stream)
109public StreamReader(Stream stream, bool detectEncodingFromByteOrderMarks)
114public StreamReader(Stream stream, Encoding? encoding)
119public StreamReader(Stream stream, Encoding? encoding, bool detectEncodingFromByteOrderMarks)
134public StreamReader(Stream stream, Encoding? encoding, bool detectEncodingFromByteOrderMarks, int bufferSize)
139public StreamReader(Stream stream, Encoding? encoding = null, bool detectEncodingFromByteOrderMarks = true, int bufferSize = -1, bool leaveOpen = false)
271public virtual Stream BaseStream => _stream;
881/// that has been read from the current <see cref="Stream"/> but not stored (by the
1009/// that has been read from the current <see cref="Stream"/> but not stored (by the
1109Stream tmpStream = _stream;
1320Stream tmpStream = _stream;
src\libraries\System.Private.CoreLib\src\System\Resources\ResourceReader.Core.cs (9)
26private static Func<object?, Stream, object>? s_deserializeMethod;
32internal ResourceReader(Stream stream, Dictionary<string, ResourceLocator> resCache, bool permitDeserialization)
105MethodInfo? binaryFormatterDeserialize = binaryFormatterType.GetMethod("Deserialize", [typeof(Stream)]);
106Func<object?, Stream, object>? deserializeMethod = (Func<object?, Stream, object>?)
124private static Func<object, Stream, object> CreateUntypedDelegate<TInstance>(MethodInfo method)
126Func<TInstance, Stream, object> typedDelegate = (Func<TInstance, Stream, object>)Delegate.CreateDelegate(typeof(Func<TInstance, Stream, object>), null, method);
System.Private.DataContractSerialization (70)
System\Runtime\Serialization\Json\JsonReaderWriterFactory.cs (7)
17public static XmlDictionaryReader CreateJsonReader(Stream stream, XmlDictionaryReaderQuotas quotas)
29public static XmlDictionaryReader CreateJsonReader(Stream stream, Encoding? encoding, XmlDictionaryReaderQuotas quotas, OnXmlDictionaryReaderClose? onClose)
48public static XmlDictionaryWriter CreateJsonWriter(Stream stream)
53public static XmlDictionaryWriter CreateJsonWriter(Stream stream, Encoding encoding)
58public static XmlDictionaryWriter CreateJsonWriter(Stream stream, Encoding encoding, bool ownsStream)
63public static XmlDictionaryWriter CreateJsonWriter(Stream stream, Encoding encoding, bool ownsStream, bool indent)
68public static XmlDictionaryWriter CreateJsonWriter(Stream stream, Encoding encoding, bool ownsStream, bool indent, string? indentChars)
System\Xml\XmlDictionaryReader.cs (11)
62public static XmlDictionaryReader CreateBinaryReader(Stream stream, XmlDictionaryReaderQuotas quotas)
67public static XmlDictionaryReader CreateBinaryReader(Stream stream, IXmlDictionary? dictionary, XmlDictionaryReaderQuotas quotas)
72public static XmlDictionaryReader CreateBinaryReader(Stream stream, IXmlDictionary? dictionary, XmlDictionaryReaderQuotas quotas, XmlBinaryReaderSession? session)
77public static XmlDictionaryReader CreateBinaryReader(Stream stream,
110public static XmlDictionaryReader CreateTextReader(Stream stream, XmlDictionaryReaderQuotas quotas)
115public static XmlDictionaryReader CreateTextReader(Stream stream, Encoding? encoding,
124public static XmlDictionaryReader CreateMtomReader(Stream stream, Encoding encoding, XmlDictionaryReaderQuotas quotas)
131public static XmlDictionaryReader CreateMtomReader(Stream stream, Encoding[] encodings, XmlDictionaryReaderQuotas quotas)
136public static XmlDictionaryReader CreateMtomReader(Stream stream, Encoding[] encodings, string? contentType, XmlDictionaryReaderQuotas quotas)
141public static XmlDictionaryReader CreateMtomReader(Stream stream, Encoding[] encodings, string? contentType,
186public virtual void StartCanonicalization(Stream stream, bool includeComments, string[]? inclusivePrefixes)
System\Xml\XmlDictionaryWriter.cs (11)
20public static XmlDictionaryWriter CreateBinaryWriter(Stream stream)
25public static XmlDictionaryWriter CreateBinaryWriter(Stream stream, IXmlDictionary? dictionary)
30public static XmlDictionaryWriter CreateBinaryWriter(Stream stream, IXmlDictionary? dictionary, XmlBinaryWriterSession? session)
35public static XmlDictionaryWriter CreateBinaryWriter(Stream stream, IXmlDictionary? dictionary, XmlBinaryWriterSession? session, bool ownsStream)
42public static XmlDictionaryWriter CreateTextWriter(Stream stream)
47public static XmlDictionaryWriter CreateTextWriter(Stream stream, Encoding encoding)
52public static XmlDictionaryWriter CreateTextWriter(Stream stream, Encoding encoding, bool ownsStream)
60public static XmlDictionaryWriter CreateMtomWriter(Stream stream, Encoding encoding, int maxSizeInBytes, string startInfo)
65public static XmlDictionaryWriter CreateMtomWriter(Stream stream, Encoding encoding, int maxSizeInBytes, string startInfo, string? boundary, string? startUri, bool writeMessageHeaders, bool ownsStream)
195Stream stream = value.GetStream();
231public virtual void StartCanonicalization(Stream stream, bool includeComments, string[]? inclusivePrefixes)
System.Private.Windows.Core (49)
System\Private\Windows\BinaryFormat\BinaryFormatWriter.cs (35)
43public static void WriteString(Stream stream, string value)
52public static void WriteDecimal(Stream stream, decimal value)
77public static void WriteDateTime(Stream stream, DateTime value)
98public static void WriteTimeSpan(Stream stream, TimeSpan value)
110public static void WriteNativeInt(Stream stream, nint value)
122public static void WriteNativeUInt(Stream stream, nuint value)
134public static void WritePoint(Stream stream, Point value)
153public static void WriteRectangle(Stream stream, Rectangle value)
176public static void WriteSize(Stream stream, Size value)
195public static void WritePointF(Stream stream, PointF value)
214public static void WriteRectangleF(Stream stream, RectangleF value)
237public static void WriteSizeF(Stream stream, SizeF value)
256public static void WriteColor(Stream stream, Color value)
283public static bool TryWritePrimitive(Stream stream, object primitive)
292public static void WritePrimitive(Stream stream, object primitive)
340public static void WriteStringList(Stream stream, List<string> list)
368public static void WritePrimitiveList<T>(Stream stream, List<T> list)
401public static bool TryWritePrimitiveList(Stream stream, IList list)
408static bool Write(Stream stream, IList list)
469public static bool TryWriteArrayList(Stream stream, ArrayList list)
473static bool Write(Stream stream, ArrayList list)
500public static bool TryWriteArray(Stream stream, Array array)
504static bool Write(Stream stream, Array array)
565public static bool TryWriteHashtable(Stream stream, Hashtable hashtable)
579public static void WritePrimitiveHashtable(Stream stream, Hashtable hashtable)
634public static void WriteNotSupportedException(Stream stream, NotSupportedException exception)
673public static bool TryWriteFrameworkObject(Stream stream, object value)
677static bool Write(Stream stream, object value)
727public static bool TryWriteDrawingPrimitivesObject(Stream stream, object value)
731static bool Write(Stream stream, object value)
756public static bool TryWriteJsonData(Stream stream, object value)
781public static bool TryWrite<T>(Action<Stream, T> action, Stream stream, T value)
791public static bool TryWrite<T>(Func<Stream, T, bool> func, Stream stream, T value)
System.Private.Windows.GdiPlus (1)
System.Private.Xml (134)
System\Xml\Core\XmlTextReaderImpl.cs (23)
122public Stream? inputStream;
449internal XmlTextReaderImpl(Stream input) : this(string.Empty, input, new NameTable())
453internal XmlTextReaderImpl(Stream input, XmlNameTable nt) : this(string.Empty, input, nt)
457internal XmlTextReaderImpl(string url, Stream input) : this(url, input, new NameTable())
461internal XmlTextReaderImpl(string? url, Stream input, XmlNameTable nt) : this(nt)
505internal XmlTextReaderImpl(Stream xmlFragment, XmlNodeType fragType, XmlParserContext? context)
628Stream? stream;
638Task<object> t = _laterInitParam.inputUriResolver.GetEntityAsync(_laterInitParam.inputbaseUri, string.Empty, typeof(Stream));
639stream = (Stream)t.GetAwaiter().GetResult();
643stream = (Stream?)_laterInitParam.inputUriResolver.GetEntity(_laterInitParam.inputbaseUri, string.Empty, typeof(Stream));
682internal XmlTextReaderImpl(Stream stream, byte[]? bytes, int byteCount, XmlReaderSettings settings, Uri? baseUri, string? baseUriStr,
2818private void InitStreamInput(Stream stream, Encoding? encoding)
2823private void InitStreamInput(string baseUriStr, Stream stream, Encoding? encoding)
2829private void InitStreamInput(Uri? baseUri, Stream stream, Encoding? encoding)
2835private void InitStreamInput(Uri? baseUri, string baseUriStr, Stream stream, Encoding? encoding)
2840private void InitStreamInput(Uri? baseUri, string baseUriStr, Stream stream, byte[]? bytes, int byteCount, Encoding? encoding)
3068_ps.stream = (Stream?)tmpResolver.GetEntity(_ps.baseUri, null, typeof(Stream));
7967Debug.Assert(_xmlResolver.SupportsType(uri, typeof(Stream)), "Stream must always be a supported type in XmlResolver");
7969Stream? stream = (Stream?)_xmlResolver.GetEntity(uri, null, typeof(Stream));
System\Xml\Core\XmlTextReaderImplAsync.cs (9)
77Stream stream = (Stream)(await _laterInitParam!.inputUriResolver!.GetEntityAsync(_laterInitParam.inputbaseUri!, string.Empty, typeof(Stream)).ConfigureAwait(false));
860private Task InitStreamInputAsync(Uri baseUri, Stream stream, Encoding? encoding)
866private async Task InitStreamInputAsync(Uri? baseUri, string baseUriStr, Stream stream, byte[]? bytes, int byteCount, Encoding? encoding)
5178Debug.Assert(_xmlResolver.SupportsType(uri, typeof(Stream)), "Stream must always be a supported type in XmlResolver");
5180Stream stream = (Stream)await _xmlResolver.GetEntityAsync(uri, null, typeof(Stream)).ConfigureAwait(false);
System\Xml\XmlDownloadManager.cs (5)
13internal static Stream GetStream(Uri uri, ICredentials? credentials, IWebProxy? proxy)
27internal static Task<Stream> GetStreamAsync(Uri uri, ICredentials? credentials, IWebProxy? proxy)
32return Task.FromResult<Stream>(new FileStream(fileUri.LocalPath, FileMode.Open, FileAccess.Read, FileShare.Read, 1, useAsync: true));
40private static async Task<Stream> GetNonFileStreamAsync(Uri uri, ICredentials? credentials, IWebProxy? proxy)
56using (Stream respStream = await client.GetStreamAsync(uri).ConfigureAwait(false))
System\Xml\Xslt\XslTransform.cs (4)
139public void Transform(XPathNavigator input, XsltArgumentList? args, Stream output, XmlResolver? resolver)
146public void Transform(XPathNavigator input, XsltArgumentList? args, Stream output)
192public void Transform(IXPathNavigable input, XsltArgumentList? args, Stream output, XmlResolver? resolver)
199public void Transform(IXPathNavigable input, XsltArgumentList? args, Stream output)
System.Private.Xml.Linq (54)
System\Xml\Linq\XDocument.cs (24)
161/// <see cref="Stream"/>, a <see cref="TextReader"/>, or an
225/// the passed <see cref="Stream"/> parameter.
228/// A <see cref="Stream"/> containing the raw XML to read into the newly
233/// <see cref="Stream"/>.
235public static XDocument Load(Stream stream)
242/// the passed <see cref="Stream"/> parameter. Optionally whitespace handling
251/// A <see cref="Stream"/> containing the raw XML to read into the newly
259/// <see cref="Stream"/>.
261public static XDocument Load(Stream stream, LoadOptions options)
272/// the passed <see cref="Stream"/> parameter. Optionally whitespace handling
281/// A <see cref="Stream"/> containing the raw XML to read into the newly
292/// <see cref="Stream"/>.
294public static async Task<XDocument> LoadAsync(Stream stream, LoadOptions options, CancellationToken cancellationToken)
561/// Output this <see cref="XDocument"/> to the passed in <see cref="Stream"/>.
566/// <see cref="XDocument.Save(Stream, SaveOptions)"/>) enabling
572/// The <see cref="Stream"/> to output this <see cref="XDocument"/> to.
574public void Save(Stream stream)
580/// Output this <see cref="XDocument"/> to a <see cref="Stream"/>.
583/// The <see cref="Stream"/> to output the XML to.
589public void Save(Stream stream, SaveOptions options)
609/// Output this <see cref="XDocument"/> to a <see cref="Stream"/>.
612/// The <see cref="Stream"/> to output the XML to.
619public async Task SaveAsync(Stream stream, SaveOptions options, CancellationToken cancellationToken)
720/// be saved to a file, a <see cref="Stream"/>, a <see cref="TextWriter"/>,
System\Xml\Linq\XElement.cs (24)
171/// be saved to a file, a <see cref="Stream"/>, a <see cref="TextWriter"/>,
546/// <see cref="Stream"/>, a <see cref="TextReader"/>, or an
613/// the passed <see cref="Stream"/> parameter.
616/// A <see cref="Stream"/> containing the raw XML to read into the newly
621/// <see cref="Stream"/>.
623public static XElement Load(Stream stream)
630/// the passed <see cref="Stream"/> parameter. Optionally whitespace handling
639/// A <see cref="Stream"/> containing the raw XML to read into the newly
647/// <see cref="Stream"/>.
649public static XElement Load(Stream stream, LoadOptions options)
660/// the passed <see cref="Stream"/> parameter. Optionally whitespace handling
669/// A <see cref="Stream"/> containing the raw XML to read into the newly
679/// <see cref="Stream"/>.
681public static async Task<XElement> LoadAsync(Stream stream, LoadOptions options, CancellationToken cancellationToken)
1032/// Output this <see cref="XElement"/> to the passed in <see cref="Stream"/>.
1037/// <see cref="XElement.Save(Stream, SaveOptions)"/>) enabling
1043/// The <see cref="Stream"/> to output this <see cref="XElement"/> to.
1045public void Save(Stream stream)
1051/// Output this <see cref="XElement"/> to a <see cref="Stream"/>.
1054/// The <see cref="Stream"/> to output the XML to.
1060public void Save(Stream stream, SaveOptions options)
1070/// Output this <see cref="XElement"/> to a <see cref="Stream"/>.
1073/// The <see cref="Stream"/> to output the XML to.
1080public async Task SaveAsync(Stream stream, SaveOptions options, CancellationToken cancellationToken)
System.Reflection.Context (2)
System.Reflection.Emit (5)
System.Reflection.Metadata (31)
System.Reflection.MetadataLoadContext (9)
System.Resources.Extensions (16)
System.Resources.Writer (11)
System.Runtime (1)
System.Runtime.Serialization.Formatters (6)
System.Security.Cryptography (192)
System\Security\Cryptography\CryptographicOperations.cs (11)
226public static byte[] HashData(HashAlgorithmName hashAlgorithm, Stream source)
262public static int HashData(HashAlgorithmName hashAlgorithm, Stream source, Span<byte> destination)
310Stream source,
359Stream source,
542public static byte[] HmacData(HashAlgorithmName hashAlgorithm, byte[] key, Stream source)
574public static byte[] HmacData(HashAlgorithmName hashAlgorithm, ReadOnlySpan<byte> key, Stream source)
612public static int HmacData(HashAlgorithmName hashAlgorithm, ReadOnlySpan<byte> key, Stream source, Span<byte> destination)
657Stream source,
702Stream source,
749Stream source,
759private static void CheckStream([NotNull] Stream source)
System\Security\Cryptography\CryptoStream.cs (7)
17private readonly Stream _stream;
33public CryptoStream(Stream stream, ICryptoTransform transform, CryptoStreamMode mode)
38public CryptoStream(Stream stream, ICryptoTransform transform, CryptoStreamMode mode, bool leaveOpen)
685public override unsafe void CopyTo(Stream destination, int bufferSize)
713public override Task CopyToAsync(Stream destination, int bufferSize, CancellationToken cancellationToken)
719private async Task CopyToAsyncInternal(Stream destination, int bufferSize, CancellationToken cancellationToken)
742private void CheckCopyToArguments(Stream destination, int bufferSize)
System\Security\Cryptography\DSA.cs (7)
92protected virtual byte[] HashData(Stream data, HashAlgorithmName hashAlgorithm) =>
241public virtual byte[] SignData(Stream data, HashAlgorithmName hashAlgorithm)
271public byte[] SignData(Stream data, HashAlgorithmName hashAlgorithm, DSASignatureFormat signatureFormat)
293protected virtual byte[] SignDataCore(Stream data, HashAlgorithmName hashAlgorithm, DSASignatureFormat signatureFormat)
384public virtual bool VerifyData(Stream data, byte[] signature, HashAlgorithmName hashAlgorithm)
696Stream data,
724Stream data,
System\Security\Cryptography\LiteHashProvider.cs (11)
13internal static int HashStream(string hashAlgorithmId, Stream source, Span<byte> destination)
19internal static byte[] HashStream(string hashAlgorithmId, int hashSizeInBytes, Stream source)
30Stream source,
45Stream source,
60Stream source,
71Stream source)
83Stream source,
99Stream source,
112private static int ProcessStream<T>(T hash, Stream source, Span<byte> destination) where T : ILiteHash
141Stream source,
173Stream source,
System\Security\Cryptography\LiteHashProvider.Xof.cs (9)
13internal static void XofStream(string hashAlgorithmId, Stream source, Span<byte> destination)
20internal static byte[] XofStream(string hashAlgorithmId, int outputLength, Stream source)
33Stream source,
47Stream source,
59Stream source,
75Stream source,
90Stream source,
108Stream source,
126Stream source,
System.Security.Cryptography.Cose (32)
System\Security\Cryptography\Cose\CoseMultiSignMessage.cs (12)
187public static byte[] SignDetached(Stream detachedContent, CoseSigner signer, CoseHeaderMap? protectedHeaders = null, CoseHeaderMap? unprotectedHeaders = null, ReadOnlySpan<byte> associatedData = default)
203Stream? contentStream,
253Stream detachedContent,
280Stream content,
372Stream? contentStream,
398Stream content,
452Stream? contentStream)
477Stream contentStream,
763public void AddSignatureForDetached(Stream detachedContent, CoseSigner signer, ReadOnlySpan<byte> associatedData = default)
778private void AddSignatureCore(ReadOnlySpan<byte> contentBytes, Stream? contentStream, CoseSigner signer, ReadOnlySpan<byte> associatedData)
839public Task AddSignatureForDetachedAsync(Stream detachedContent, CoseSigner signer, ReadOnlyMemory<byte> associatedData = default, CancellationToken cancellationToken = default)
854private async Task AddSignatureCoreAsync(Stream content, CoseSigner signer, ReadOnlyMemory<byte> associatedData, CancellationToken cancellationToken)
System\Security\Cryptography\Cose\CoseSign1Message.cs (12)
161public static byte[] SignDetached(Stream detachedContent, CoseSigner signer, ReadOnlySpan<byte> associatedData = default)
178internal static byte[] SignCore(ReadOnlySpan<byte> contentBytes, Stream? contentStream, CoseSigner signer, ReadOnlySpan<byte> associatedData, bool isDetached)
215public static Task<byte[]> SignDetachedAsync(Stream detachedContent, CoseSigner signer, ReadOnlyMemory<byte> associatedData = default, CancellationToken cancellationToken = default)
235private static async Task<byte[]> SignAsyncCore(int expectedSize, Stream content, CoseSigner signer, ReadOnlyMemory<byte> associatedData, CancellationToken cancellationToken)
321private static int CreateCoseSign1Message(ReadOnlySpan<byte> contentBytes, Stream? contentStream, Span<byte> buffer, CoseSigner signer, ReadOnlySpan<byte> associatedData, bool isDetached)
344private static async Task<int> CreateCoseSign1MessageAsync(Stream content, byte[] buffer, CoseSigner signer, ReadOnlyMemory<byte> associatedData, CancellationToken cancellationToken)
578/// <seealso cref="VerifyDetachedAsync(AsymmetricAlgorithm, Stream, ReadOnlyMemory{byte}, CancellationToken)"/>
580public bool VerifyDetached(AsymmetricAlgorithm key, Stream detachedContent, ReadOnlySpan<byte> associatedData = default)
609private bool VerifyCore(AsymmetricAlgorithm key, ReadOnlySpan<byte> contentBytes, Stream? contentStream, ReadOnlySpan<byte> associatedData, KeyType keyType)
679/// <seealso cref="VerifyDetached(AsymmetricAlgorithm, Stream, ReadOnlySpan{byte})"/>
681public Task<bool> VerifyDetachedAsync(AsymmetricAlgorithm key, Stream detachedContent, ReadOnlyMemory<byte> associatedData = default, CancellationToken cancellationToken = default)
710private async Task<bool> VerifyAsyncCore(AsymmetricAlgorithm key, Stream content, ReadOnlyMemory<byte> associatedData, KeyType keyType, CancellationToken cancellationToken)
System\Security\Cryptography\Cose\CoseSignature.cs (6)
286/// <seealso cref="VerifyDetachedAsync(AsymmetricAlgorithm, Stream, ReadOnlyMemory{byte}, CancellationToken)"/>
288public bool VerifyDetached(AsymmetricAlgorithm key, Stream detachedContent, ReadOnlySpan<byte> associatedData = default)
354/// <seealso cref="VerifyDetached(AsymmetricAlgorithm, Stream, ReadOnlySpan{byte})"/>
356public Task<bool> VerifyDetachedAsync(AsymmetricAlgorithm key, Stream detachedContent, ReadOnlyMemory<byte> associatedData = default, CancellationToken cancellationToken = default)
385private async Task<bool> VerifyAsyncCore(AsymmetricAlgorithm key, Stream content, ReadOnlyMemory<byte> associatedData, KeyType keyType, CancellationToken cancellationToken)
419private bool VerifyCore(AsymmetricAlgorithm key, ReadOnlySpan<byte> contentBytes, Stream? contentStream, ReadOnlySpan<byte> associatedData, KeyType keyType)
System.Security.Cryptography.Xml (66)
System.ServiceModel.NetFramingBase (19)
System.ServiceModel.Primitives (4)
System.ServiceModel.UnixDomainSocket (2)
System.Speech (15)
artifacts\obj\System.Speech\Debug\net10.0\System.Speech.notsupported.cs (15)
117public Grammar(System.IO.Stream stream) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
118public Grammar(System.IO.Stream stream, string ruleName) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
119public Grammar(System.IO.Stream stream, string ruleName, object[] parameters) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
121public Grammar(System.IO.Stream stream, string ruleName, System.Uri baseUri) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
123public Grammar(System.IO.Stream stream, string ruleName, System.Uri baseUri, object[] parameters) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
222public void WriteToAudioStream(System.IO.Stream outputStream) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
223public void WriteToWaveStream(System.IO.Stream outputStream) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
384public void SetInputToAudioStream(System.IO.Stream audioSource, System.Speech.AudioFormat.SpeechAudioFormatInfo audioFormat) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
388public void SetInputToWaveStream(System.IO.Stream audioSource) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
493public static void Compile(System.Speech.Recognition.SrgsGrammar.SrgsDocument srgsGrammar, System.IO.Stream outputStream) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
494public static void Compile(string inputPath, System.IO.Stream outputStream) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
495public static void Compile(System.Xml.XmlReader reader, System.IO.Stream outputStream) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
834public void SetOutputToAudioStream(System.IO.Stream audioDestination, System.Speech.AudioFormat.SpeechAudioFormatInfo formatInfo) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
839public void SetOutputToWaveStream(System.IO.Stream audioDestination) { throw new System.PlatformNotSupportedException(System.SR.PlatformNotSupported_SystemSpeech); }
1004System.IO.Stream LoadResource(System.Uri uri, string mediaType);
System.Text.Encoding.CodePages (7)
System.Text.Json (92)
System\Text\Json\Serialization\JsonSerializer.Read.Stream.cs (16)
45Stream utf8Json,
81Stream utf8Json,
119Stream utf8Json,
160Stream utf8Json,
197Stream utf8Json,
232Stream utf8Json,
266Stream utf8Json,
297Stream utf8Json,
341Stream utf8Json,
388Stream utf8Json,
424Stream utf8Json,
453Stream utf8Json,
480Stream utf8Json,
507Stream utf8Json,
527Stream utf8Json,
549Stream utf8Json,
System\Text\Json\Serialization\JsonSerializer.Write.Stream.cs (30)
24/// Converts the provided value to UTF-8 encoded JSON text and write it to the <see cref="System.IO.Stream"/>.
28/// <param name="utf8Json">The UTF-8 <see cref="System.IO.Stream"/> to write to.</param>
42Stream utf8Json,
57/// Converts the provided value to UTF-8 encoded JSON text and write it to the <see cref="System.IO.Stream"/>.
60/// <param name="utf8Json">The UTF-8 <see cref="System.IO.Stream"/> to write to.</param>
73Stream utf8Json,
87/// Converts the provided value to UTF-8 encoded JSON text and write it to the <see cref="System.IO.Stream"/>.
90/// <param name="utf8Json">The UTF-8 <see cref="System.IO.Stream"/> to write to.</param>
108Stream utf8Json,
125/// Converts the provided value to UTF-8 encoded JSON text and write it to the <see cref="System.IO.Stream"/>.
127/// <param name="utf8Json">The UTF-8 <see cref="System.IO.Stream"/> to write to.</param>
144Stream utf8Json,
160/// Converts the provided value to UTF-8 encoded JSON text and write it to the <see cref="System.IO.Stream"/>.
164/// <param name="utf8Json">The UTF-8 <see cref="System.IO.Stream"/> to write to.</param>
172Stream utf8Json,
191/// Converts the provided value to UTF-8 encoded JSON text and write it to the <see cref="System.IO.Stream"/>.
194/// <param name="utf8Json">The UTF-8 <see cref="System.IO.Stream"/> to write to.</param>
201Stream utf8Json,
219/// Converts the provided value to UTF-8 encoded JSON text and write it to the <see cref="System.IO.Stream"/>.
222/// <param name="utf8Json">The UTF-8 <see cref="System.IO.Stream"/> to write to.</param>
233Stream utf8Json,
252/// Converts the provided value to UTF-8 encoded JSON text and write it to the <see cref="System.IO.Stream"/>.
254/// <param name="utf8Json">The UTF-8 <see cref="System.IO.Stream"/> to write to.</param>
264Stream utf8Json,
282/// Converts the provided value to UTF-8 encoded JSON text and write it to the <see cref="System.IO.Stream"/>.
285/// <param name="utf8Json">The UTF-8 <see cref="System.IO.Stream"/> to write to.</param>
301Stream utf8Json,
322/// Converts the provided value to UTF-8 encoded JSON text and write it to the <see cref="System.IO.Stream"/>.
324/// <param name="utf8Json">The UTF-8 <see cref="System.IO.Stream"/> to write to.</param>
339Stream utf8Json,
System\Text\Json\Serialization\JsonSerializer.Write.String.cs (5)
26/// and <see cref="SerializeAsync{TValue}(IO.Stream, TValue, JsonSerializerOptions?, Threading.CancellationToken)"/>.
55/// and <see cref="SerializeAsync(IO.Stream, object?, Type, JsonSerializerOptions?, Threading.CancellationToken)"/>.
81/// and <see cref="SerializeAsync{TValue}(IO.Stream, TValue, JsonTypeInfo{TValue}, Threading.CancellationToken)"/>.
108/// and <see cref="SerializeAsync(IO.Stream, object?, JsonTypeInfo, Threading.CancellationToken)"/>.
141/// and <see cref="SerializeAsync(IO.Stream, object?, Type, JsonSerializerContext, Threading.CancellationToken)"/>.
System.Windows.Extensions (2)
System.Windows.Forms (46)
System.Windows.Forms.Design (20)
System.Windows.Forms.Design.Tests (13)
System.Windows.Forms.Primitives (5)
System.Windows.Forms.Primitives.TestUtilities (2)
System.Windows.Forms.Tests (18)
System.Windows.Forms.UI.IntegrationTests (13)
System.Xaml (9)
System.Xaml.Tests (2)
Templates.Tests (1)
UnitTests.Common (6)
vbc (6)
VBCSCompiler (7)
WindowsBase.Tests (1)
WinShimmer (1)
WsFedSample (1)
xunit.console (11)