style: Removed '#nullable disable' from the Libplanet.Net project (etc)

Libplanet.Net.Tests/BlockCandidateTableTest.cs

@@ -24,14 +24,14 @@ public void Add()
 
             // Ignore existing key
             var firstBranch = new Branch(
-                new List<(Block, BlockCommit)>
+                new List<(Block, BlockCommit?)>
                 {
                     (_fx.Block2, TestUtils.CreateBlockCommit(_fx.Block2)),
                     (_fx.Block3, TestUtils.CreateBlockCommit(_fx.Block3)),
                     (_fx.Block4, TestUtils.CreateBlockCommit(_fx.Block4)),
                 });
             var secondBranch = new Branch(
-                new List<(Block, BlockCommit)>
+                new List<(Block, BlockCommit?)>
                 {
                     (_fx.Block3, TestUtils.CreateBlockCommit(_fx.Block3)),
                     (_fx.Block4, TestUtils.CreateBlockCommit(_fx.Block4)),

Libplanet.Net/AppProtocolVersion.cs

@@ -1,4 +1,3 @@
-#nullable disable
 using System;
 using System.Collections.Immutable;
 using System.Diagnostics.Contracts;
@@ -34,7 +33,7 @@ namespace Libplanet.Net
         /// Optional extra data about the version.  This can be used for any purpose
         /// by apps, such as a URL to download the software.
         /// </summary>
-        public readonly IValue Extra;
+        public readonly IValue? Extra;
 
         /// <summary>
         /// A signer who claims presence of a version.
@@ -54,7 +53,7 @@ namespace Libplanet.Net
         /// <param name="signer">Gets the <see cref="Signer"/>.</param>
         public AppProtocolVersion(
             int version,
-            IValue extra,
+            IValue? extra,
             ImmutableArray<byte> signature,
             Address signer
         )
@@ -121,7 +120,7 @@ public string Token
         /// <returns>A signed version claim.</returns>
         /// <exception cref="ArgumentNullException">Thrown when <paramref name="signer"/> is
         /// <see langword="null"/>.</exception>
-        public static AppProtocolVersion Sign(PrivateKey signer, int version, IValue extra = null)
+        public static AppProtocolVersion Sign(PrivateKey signer, int version, IValue? extra = null)
         {
             if (signer is null)
             {
@@ -201,7 +200,7 @@ public static AppProtocolVersion FromToken(string token)
                 throw new FormatException($"Failed to parse a signature: {token}", e);
             }
 
-            IValue extra = null;
+            IValue? extra = null;
             if (pos >= 0)
             {
                 pos++;
@@ -246,7 +245,7 @@ other field values.  A value of this struct can represent an invalid claim. */
 
         /// <inheritdoc/>
         [Pure]
-        public override bool Equals(object obj) =>
+        public override bool Equals(object? obj) =>
             obj is AppProtocolVersion other && Equals(other);
 
         /// <inheritdoc/>
@@ -279,7 +278,7 @@ public override string ToString() => string.Format(
         /// </summary>
         /// <returns>A deterministic message to sign.</returns>
         [Pure]
-        private static byte[] GetMessage(int version, IValue extra)
+        private static byte[] GetMessage(int version, IValue? extra)
         {
             byte[] msg = NetworkOrderBitsConverter.GetBytes(version);
             if (!(extra is null))

Libplanet.Net/AssemblyInfo.cs

@@ -1,4 +1,3 @@
-#nullable disable
 using System.Runtime.CompilerServices;
 
 [assembly: InternalsVisibleTo("Libplanet.Benchmarks")]

Libplanet.Net/BlockCompletion.cs

@@ -1,4 +1,3 @@
-#nullable disable
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
@@ -16,16 +15,17 @@
 namespace Libplanet.Net
 {
     internal class BlockCompletion<TPeer>
+        where TPeer : notnull
     {
         private readonly ILogger _logger;
-        private readonly Func<BlockHash, bool> _completionPredicate;
+        private readonly Func<BlockHash, bool>? _completionPredicate;
         private readonly int _window;
         private readonly ConcurrentDictionary<BlockHash, bool> _satisfiedBlocks;
         private readonly ConcurrentQueue<BlockHash> _demands;
         private readonly SemaphoreSlim _demandEnqueued;
         private bool _started;
 
-        public BlockCompletion(Func<BlockHash, bool> completionPredicate = null, int window = 100)
+        public BlockCompletion(Func<BlockHash, bool>? completionPredicate = null, int window = 100)
         {
             _logger = Log.ForContext<BlockCompletion<TPeer>>();
             _completionPredicate = completionPredicate;
@@ -36,7 +36,7 @@ public BlockCompletion(Func<BlockHash, bool> completionPredicate = null, int win
             _demandEnqueued = new SemaphoreSlim(0);
         }
 
-        public delegate IAsyncEnumerable<(Block, BlockCommit)> BlockFetcher(
+        public delegate IAsyncEnumerable<(Block, BlockCommit?)> BlockFetcher(
             TPeer peer,
             IEnumerable<BlockHash> blockHashes,
             CancellationToken cancellationToken
@@ -182,7 +182,7 @@ public bool Satisfy(Block block)
         /// for the task to complete.</param>
         /// <returns>An async enumerable that yields pairs of a fetched block and its source
         /// peer.  It terminates when all demands are satisfied.</returns>
-        public async IAsyncEnumerable<Tuple<Block, BlockCommit, TPeer>> Complete(
+        public async IAsyncEnumerable<Tuple<Block, BlockCommit?, TPeer>> Complete(
             IReadOnlyList<TPeer> peers,
             BlockFetcher blockFetcher,
             [EnumeratorCancellation] CancellationToken cancellationToken = default
@@ -195,7 +195,7 @@ public async IAsyncEnumerable<Tuple<Block, BlockCommit, TPeer>> Complete(
 
             var pool = new PeerPool(peers);
             var queue =
-                new AsyncProducerConsumerQueue<Tuple<Block, BlockCommit, TPeer>>();
+                new AsyncProducerConsumerQueue<Tuple<Block, BlockCommit?, TPeer>>();
 
             Task producer = Task.Run(async () =>
             {
@@ -229,7 +229,7 @@ await pool.SpawnAsync(
 
             while (await queue.OutputAvailableAsync(cancellationToken))
             {
-                Tuple<Block, BlockCommit, TPeer> triple;
+                Tuple<Block, BlockCommit?, TPeer> triple;
                 try
                 {
                     triple = await queue.DequeueAsync(cancellationToken);
@@ -291,7 +291,7 @@ private Func<TPeer, CancellationToken, Task> CreateEnqueuing(
             IList<BlockHash> blockHashes,
             BlockFetcher blockFetcher,
             CancellationToken cancellationToken,
-            AsyncProducerConsumerQueue<Tuple<Block, BlockCommit, TPeer>> queue
+            AsyncProducerConsumerQueue<Tuple<Block, BlockCommit?, TPeer>> queue
         ) =>
             async (peer, ct) =>
             {
@@ -307,10 +307,10 @@ AsyncProducerConsumerQueue<Tuple<Block, BlockCommit, TPeer>> queue
 
                     try
                     {
-                        ConfiguredCancelableAsyncEnumerable<(Block, BlockCommit)> blocks =
+                        ConfiguredCancelableAsyncEnumerable<(Block, BlockCommit?)> blocks =
                             blockFetcher(peer, blockHashes, cancellationToken)
                                 .WithCancellation(cancellationToken);
-                        await foreach ((Block block, BlockCommit commit) in blocks)
+                        await foreach ((Block block, BlockCommit? commit) in blocks)
                         {
                             _logger.Debug(
                                 "Downloaded block #{BlockIndex} {BlockHash} from {Peer}",
@@ -405,7 +405,7 @@ public async Task SpawnAsync(
                     cancellationToken.ThrowIfCancellationRequested();
                 }
 
-                if (_tasks.TryRemove(peer, out Task completeTask))
+                if (_tasks.TryRemove(peer, out Task? completeTask))
                 {
                     await completeTask;
                 }

Libplanet/Blockchain/Branch.cs

@@ -28,9 +28,9 @@ public class Branch
         ///     </description></item>
         /// </list>
         /// </exception>
-        public Branch(IEnumerable<(Block, BlockCommit)> blocks)
+        public Branch(IEnumerable<(Block, BlockCommit?)> blocks)
         {
-            ImmutableArray<(Block, BlockCommit)> sorted =
+            ImmutableArray<(Block, BlockCommit?)> sorted =
                 blocks.OrderBy(block => block.Item1.Index).ToImmutableArray();
             if (!sorted.Any())
             {
@@ -71,6 +71,6 @@ public Branch(IEnumerable<(Block, BlockCommit)> blocks)
         ///     </description></item>
         /// </list>
         /// </summary>
-        public ImmutableArray<(Block, BlockCommit)> Blocks { get; }
+        public ImmutableArray<(Block, BlockCommit?)> Blocks { get; }
     }
 }