Skip to content

Commit bfbf6d4

Browse files
authored
Add few more SB package dependencies (#732)
1 parent 606c0c3 commit bfbf6d4

File tree

10 files changed

+867
-0
lines changed

10 files changed

+867
-0
lines changed

eng/Build.props

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,10 @@
7878
<DependencyPackageProjects Include="$(RepoRoot)src\referencePackages\src\**\NuGet.Frameworks.6.6.1.csproj" />
7979
<DependencyPackageProjects Include="$(RepoRoot)src\referencePackages\src\**\NuGet.Common.6.6.1.csproj" />
8080
<DependencyPackageProjects Include="$(RepoRoot)src\referencePackages\src\**\NuGet.Configuration.6.6.1.csproj" />
81+
82+
<DependencyPackageProjects Include="$(RepoRoot)src\referencePackages\src\**\System.IO.Pipelines.6.0.3.csproj" />
83+
84+
<DependencyPackageProjects Include="$(RepoRoot)src\referencePackages\src\**\System.Threading.Channels.6.0.0.csproj" />
8185
</ItemGroup>
8286

8387
<ItemGroup Condition="'$(BuildDependencyPackageProjects)' == 'true'">
Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
<Project Sdk="Microsoft.NET.Sdk">
2+
3+
<PropertyGroup>
4+
<TargetFrameworks>net6.0;netstandard2.0</TargetFrameworks>
5+
<AssemblyName>System.IO.Pipelines</AssemblyName>
6+
<ProjectTemplateVersion>2</ProjectTemplateVersion>
7+
<StrongNameKeyId>Open</StrongNameKeyId>
8+
</PropertyGroup>
9+
10+
<ItemGroup Condition="'$(TargetFramework)' == 'netstandard2.0'">
11+
<PackageReference Include="System.Buffers" Version="4.5.1" />
12+
<PackageReference Include="System.Memory" Version="4.5.4" />
13+
<PackageReference Include="System.Threading.Tasks.Extensions" Version="4.5.4" />
14+
</ItemGroup>
15+
16+
</Project>
Lines changed: 191 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,191 @@
1+
// Licensed to the .NET Foundation under one or more agreements.
2+
// The .NET Foundation licenses this file to you under the MIT license.
3+
// See the LICENSE file in the project root for more information.
4+
// ------------------------------------------------------------------------------
5+
// Changes to this file must follow the http://aka.ms/api-review process.
6+
// ------------------------------------------------------------------------------
7+
[assembly: System.Runtime.CompilerServices.CompilationRelaxations(8)]
8+
[assembly: System.Runtime.CompilerServices.RuntimeCompatibility(WrapNonExceptionThrows = true)]
9+
[assembly: System.Diagnostics.Debuggable(System.Diagnostics.DebuggableAttribute.DebuggingModes.IgnoreSymbolStoreSequencePoints)]
10+
[assembly: System.Runtime.CompilerServices.InternalsVisibleTo("System.IO.Pipelines.Tests, PublicKey=00240000048000009400000006020000002400005253413100040000010001004b86c4cb78549b34bab61a3b1800e23bfeb5b3ec390074041536a7e3cbd97f5f04cf0f857155a8928eaa29ebfd11cfbbad3ba70efea7bda3226c6a8d370a4cd303f714486b6ebc225985a638471e6ef571cc92a4613c00b8fa65d61ccee0cbe5f36330c9a01f4183559f1bef24cc2917c6d913e3a541333a1d05d9bed22b38cb")]
11+
[assembly: System.Runtime.Versioning.TargetFramework(".NETCoreApp,Version=v6.0", FrameworkDisplayName = "")]
12+
[assembly: System.CLSCompliant(true)]
13+
[assembly: System.Reflection.AssemblyDefaultAlias("System.IO.Pipelines")]
14+
[assembly: System.Resources.NeutralResourcesLanguage("en-US")]
15+
[assembly: System.Reflection.AssemblyMetadata(".NETFrameworkAssembly", "")]
16+
[assembly: System.Reflection.AssemblyMetadata("Serviceable", "True")]
17+
[assembly: System.Reflection.AssemblyMetadata("PreferInbox", "True")]
18+
[assembly: System.Reflection.AssemblyMetadata("IsTrimmable", "True")]
19+
[assembly: System.Reflection.AssemblyCompany("Microsoft Corporation")]
20+
[assembly: System.Reflection.AssemblyCopyright("© Microsoft Corporation. All rights reserved.")]
21+
[assembly: System.Reflection.AssemblyDescription("Single producer single consumer byte buffer management.\r\n\r\nCommonly Used Types:\r\nSystem.IO.Pipelines.Pipe\r\nSystem.IO.Pipelines.PipeWriter\r\nSystem.IO.Pipelines.PipeReader")]
22+
[assembly: System.Reflection.AssemblyFileVersion("6.0.522.21309")]
23+
[assembly: System.Reflection.AssemblyInformationalVersion("6.0.5+70ae3df4a6f3c92fb6b315afc405edd10ff38579")]
24+
[assembly: System.Reflection.AssemblyProduct("Microsoft® .NET")]
25+
[assembly: System.Reflection.AssemblyTitle("System.IO.Pipelines")]
26+
[assembly: System.Reflection.AssemblyMetadata("RepositoryUrl", "https://github.com/dotnet/runtime")]
27+
[assembly: System.Reflection.AssemblyVersionAttribute("6.0.0.0")]
28+
[assembly: System.Runtime.CompilerServices.ReferenceAssembly]
29+
[assembly: System.Reflection.AssemblyFlagsAttribute((System.Reflection.AssemblyNameFlags)0x70)]
30+
namespace System.IO.Pipelines
31+
{
32+
public partial struct FlushResult
33+
{
34+
private int _dummyPrimitive;
35+
public FlushResult(bool isCanceled, bool isCompleted) { }
36+
37+
public bool IsCanceled { get { throw null; } }
38+
39+
public bool IsCompleted { get { throw null; } }
40+
}
41+
42+
public partial interface IDuplexPipe
43+
{
44+
PipeReader Input { get; }
45+
46+
PipeWriter Output { get; }
47+
}
48+
49+
public sealed partial class Pipe
50+
{
51+
public Pipe() { }
52+
53+
public Pipe(PipeOptions options) { }
54+
55+
public PipeReader Reader { get { throw null; } }
56+
57+
public PipeWriter Writer { get { throw null; } }
58+
59+
public void Reset() { }
60+
}
61+
62+
public partial class PipeOptions
63+
{
64+
public PipeOptions(Buffers.MemoryPool<byte>? pool = null, PipeScheduler? readerScheduler = null, PipeScheduler? writerScheduler = null, long pauseWriterThreshold = -1, long resumeWriterThreshold = -1, int minimumSegmentSize = -1, bool useSynchronizationContext = true) { }
65+
66+
public static PipeOptions Default { get { throw null; } }
67+
68+
public int MinimumSegmentSize { get { throw null; } }
69+
70+
public long PauseWriterThreshold { get { throw null; } }
71+
72+
public Buffers.MemoryPool<byte> Pool { get { throw null; } }
73+
74+
public PipeScheduler ReaderScheduler { get { throw null; } }
75+
76+
public long ResumeWriterThreshold { get { throw null; } }
77+
78+
public bool UseSynchronizationContext { get { throw null; } }
79+
80+
public PipeScheduler WriterScheduler { get { throw null; } }
81+
}
82+
83+
public abstract partial class PipeReader
84+
{
85+
public abstract void AdvanceTo(SequencePosition consumed, SequencePosition examined);
86+
public abstract void AdvanceTo(SequencePosition consumed);
87+
public virtual Stream AsStream(bool leaveOpen = false) { throw null; }
88+
89+
public abstract void CancelPendingRead();
90+
public abstract void Complete(Exception? exception = null);
91+
public virtual Threading.Tasks.ValueTask CompleteAsync(Exception? exception = null) { throw null; }
92+
93+
public virtual Threading.Tasks.Task CopyToAsync(PipeWriter destination, Threading.CancellationToken cancellationToken = default) { throw null; }
94+
95+
public virtual Threading.Tasks.Task CopyToAsync(Stream destination, Threading.CancellationToken cancellationToken = default) { throw null; }
96+
97+
public static PipeReader Create(Buffers.ReadOnlySequence<byte> sequence) { throw null; }
98+
99+
public static PipeReader Create(Stream stream, StreamPipeReaderOptions? readerOptions = null) { throw null; }
100+
101+
[Obsolete("OnWriterCompleted has been deprecated and may not be invoked on all implementations of PipeReader.")]
102+
public virtual void OnWriterCompleted(Action<Exception?, object?> callback, object? state) { }
103+
104+
public abstract Threading.Tasks.ValueTask<ReadResult> ReadAsync(Threading.CancellationToken cancellationToken = default);
105+
public Threading.Tasks.ValueTask<ReadResult> ReadAtLeastAsync(int minimumSize, Threading.CancellationToken cancellationToken = default) { throw null; }
106+
107+
protected virtual Threading.Tasks.ValueTask<ReadResult> ReadAtLeastAsyncCore(int minimumSize, Threading.CancellationToken cancellationToken) { throw null; }
108+
109+
public abstract bool TryRead(out ReadResult result);
110+
}
111+
112+
public abstract partial class PipeScheduler
113+
{
114+
public static PipeScheduler Inline { get { throw null; } }
115+
116+
public static PipeScheduler ThreadPool { get { throw null; } }
117+
118+
public abstract void Schedule(Action<object?> action, object? state);
119+
}
120+
121+
public abstract partial class PipeWriter : Buffers.IBufferWriter<byte>
122+
{
123+
public virtual bool CanGetUnflushedBytes { get { throw null; } }
124+
125+
public virtual long UnflushedBytes { get { throw null; } }
126+
127+
public abstract void Advance(int bytes);
128+
public virtual Stream AsStream(bool leaveOpen = false) { throw null; }
129+
130+
public abstract void CancelPendingFlush();
131+
public abstract void Complete(Exception? exception = null);
132+
public virtual Threading.Tasks.ValueTask CompleteAsync(Exception? exception = null) { throw null; }
133+
134+
protected internal virtual Threading.Tasks.Task CopyFromAsync(Stream source, Threading.CancellationToken cancellationToken = default) { throw null; }
135+
136+
public static PipeWriter Create(Stream stream, StreamPipeWriterOptions? writerOptions = null) { throw null; }
137+
138+
public abstract Threading.Tasks.ValueTask<FlushResult> FlushAsync(Threading.CancellationToken cancellationToken = default);
139+
public abstract Memory<byte> GetMemory(int sizeHint = 0);
140+
public abstract Span<byte> GetSpan(int sizeHint = 0);
141+
[Obsolete("OnReaderCompleted has been deprecated and may not be invoked on all implementations of PipeWriter.")]
142+
public virtual void OnReaderCompleted(Action<Exception?, object?> callback, object? state) { }
143+
144+
public virtual Threading.Tasks.ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, Threading.CancellationToken cancellationToken = default) { throw null; }
145+
}
146+
147+
public readonly partial struct ReadResult
148+
{
149+
private readonly int _dummyPrimitive;
150+
public ReadResult(Buffers.ReadOnlySequence<byte> buffer, bool isCanceled, bool isCompleted) { }
151+
152+
public Buffers.ReadOnlySequence<byte> Buffer { get { throw null; } }
153+
154+
public bool IsCanceled { get { throw null; } }
155+
156+
public bool IsCompleted { get { throw null; } }
157+
}
158+
159+
public static partial class StreamPipeExtensions
160+
{
161+
public static Threading.Tasks.Task CopyToAsync(this Stream source, PipeWriter destination, Threading.CancellationToken cancellationToken = default) { throw null; }
162+
}
163+
164+
public partial class StreamPipeReaderOptions
165+
{
166+
public StreamPipeReaderOptions(Buffers.MemoryPool<byte>? pool = null, int bufferSize = -1, int minimumReadSize = -1, bool leaveOpen = false, bool useZeroByteReads = false) { }
167+
168+
public StreamPipeReaderOptions(Buffers.MemoryPool<byte>? pool, int bufferSize, int minimumReadSize, bool leaveOpen) { }
169+
170+
public int BufferSize { get { throw null; } }
171+
172+
public bool LeaveOpen { get { throw null; } }
173+
174+
public int MinimumReadSize { get { throw null; } }
175+
176+
public Buffers.MemoryPool<byte> Pool { get { throw null; } }
177+
178+
public bool UseZeroByteReads { get { throw null; } }
179+
}
180+
181+
public partial class StreamPipeWriterOptions
182+
{
183+
public StreamPipeWriterOptions(Buffers.MemoryPool<byte>? pool = null, int minimumBufferSize = -1, bool leaveOpen = false) { }
184+
185+
public bool LeaveOpen { get { throw null; } }
186+
187+
public int MinimumBufferSize { get { throw null; } }
188+
189+
public Buffers.MemoryPool<byte> Pool { get { throw null; } }
190+
}
191+
}

0 commit comments

Comments
 (0)