Skip to content

Commit 4e7cb89

Browse files
Phase 1 basic updates for 2022 with use of Roslynator.
1 parent d6bf353 commit 4e7cb89

51 files changed

Lines changed: 12849 additions & 13003 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

Channel/AsChannel.cs

Lines changed: 648 additions & 649 deletions
Large diffs are not rendered by default.

Channel/CreateChannel.cs

Lines changed: 22 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -1,29 +1,28 @@
11
using System;
22
using System.Threading.Channels;
33

4-
namespace Open.Database.Extensions
4+
namespace Open.Database.Extensions;
5+
6+
public static partial class ChannelDbExtensions
57
{
6-
public static partial class ChannelDbExtensions
7-
{
8-
internal static Channel<T> CreateChannel<T>(int capacity = -1, bool singleReader = false, bool singleWriter = true)
9-
{
10-
if (capacity == 0) throw new ArgumentOutOfRangeException(nameof(capacity), capacity, "Cannot be zero.");
11-
if (capacity < -1) throw new ArgumentOutOfRangeException(nameof(capacity), capacity, "Must greater than zero or equal to negative one (unbounded).");
8+
internal static Channel<T> CreateChannel<T>(int capacity = -1, bool singleReader = false, bool singleWriter = true)
9+
{
10+
if (capacity == 0) throw new ArgumentOutOfRangeException(nameof(capacity), capacity, "Cannot be zero.");
11+
if (capacity < -1) throw new ArgumentOutOfRangeException(nameof(capacity), capacity, "Must greater than zero or equal to negative one (unbounded).");
1212

13-
return capacity > 0
14-
? Channel.CreateBounded<T>(new BoundedChannelOptions(capacity)
15-
{
16-
SingleWriter = singleWriter,
17-
SingleReader = singleReader,
18-
AllowSynchronousContinuations = true,
19-
FullMode = BoundedChannelFullMode.Wait
20-
})
21-
: Channel.CreateUnbounded<T>(new UnboundedChannelOptions
22-
{
23-
SingleWriter = singleWriter,
24-
SingleReader = singleReader,
25-
AllowSynchronousContinuations = true
26-
});
27-
}
28-
}
13+
return capacity > 0
14+
? Channel.CreateBounded<T>(new BoundedChannelOptions(capacity)
15+
{
16+
SingleWriter = singleWriter,
17+
SingleReader = singleReader,
18+
AllowSynchronousContinuations = true,
19+
FullMode = BoundedChannelFullMode.Wait
20+
})
21+
: Channel.CreateUnbounded<T>(new UnboundedChannelOptions
22+
{
23+
SingleWriter = singleWriter,
24+
SingleReader = singleReader,
25+
AllowSynchronousContinuations = true
26+
});
27+
}
2928
}

Channel/Open.Database.Extensions.Channel.csproj

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,19 +6,22 @@
66
<LangVersion>latest</LangVersion>
77
<Nullable>enable</Nullable>
88
<Authors>electricessence</Authors>
9-
<Description>Database extensions for pipelining data through channels. Includes Open.Database.Extensions.Core.</Description>
9+
<Copyright>© electricessence (Oren F.) All rights reserved.</Copyright>
1010
<PackageLicenseExpression>MIT</PackageLicenseExpression>
1111
<PackageProjectUrl>https://github.com/Open-NET-Libraries/Open.Database.Extensions</PackageProjectUrl>
1212
<RepositoryUrl>https://github.com/Open-NET-Libraries/Open.Database.Extensions</RepositoryUrl>
13-
<RepositoryType>git</RepositoryType>
13+
<Description>Database extensions for pipelining data through channels. Includes Open.Database.Extensions.Core.</Description>
14+
<PackageTags>ado;ado extensions;sql;connection factory;extensions;channel;channels</PackageTags>
1415
<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
16+
<RepositoryType>git</RepositoryType>
1517
<Version>6.6.1</Version>
1618
<PackageReleaseNotes></PackageReleaseNotes>
17-
<PackageLicenseExpression>MIT</PackageLicenseExpression>
1819
<PublishRepositoryUrl>true</PublishRepositoryUrl>
1920
<IncludeSymbols>true</IncludeSymbols>
2021
<SymbolPackageFormat>snupkg</SymbolPackageFormat>
2122
<PackageIcon>logo.png</PackageIcon>
23+
<AnalysisLevel>latest</AnalysisLevel>
24+
<EnableNETAnalyzers>True</EnableNETAnalyzers>
2225
</PropertyGroup>
2326

2427
<ItemGroup>

0 commit comments

Comments
 (0)