format

specklesystems · Dec 31, 2024 · e1f1ade · e1f1ade
1 parent 550ee2b
commit e1f1ade
Show file tree

Hide file tree

Showing 5 changed files with 25 additions and 20 deletions.
diff --git a/src/Speckle.Sdk.Dependencies/Serialization/SizeBatchingChannelReader.cs b/src/Speckle.Sdk.Dependencies/Serialization/SizeBatchingChannelReader.cs
@@ -21,7 +21,7 @@ public void Add(T item)
     _items.Add(item);
     _batchSize += item.Size;
   }
-  
+
   public void TrimExcess()
   {
     _items.TrimExcess();
@@ -32,7 +32,6 @@ public void TrimExcess()
   public List<T> Items => _items;
 }
 
-
 public class SizeBatchingChannelReader<T>(
   ChannelReader<T> source,
   int batchSize,

diff --git a/src/Speckle.Sdk/Api/Operations/Operations.Send.cs b/src/Speckle.Sdk/Api/Operations/Operations.Send.cs
@@ -25,7 +25,12 @@ public async Task<SerializeProcessResults> Send2(
 
     try
     {
-      using var process = serializeProcessFactory.CreateSerializeProcess(url, streamId, authorizationToken, onProgressAction);
+      using var process = serializeProcessFactory.CreateSerializeProcess(
+        url,
+        streamId,
+        authorizationToken,
+        onProgressAction
+      );
       var results = await process.Serialize(value, cancellationToken).ConfigureAwait(false);
 
       receiveActivity?.SetStatus(SdkActivityStatusCode.Ok);

diff --git a/src/Speckle.Sdk/Serialisation/V2/Send/PriorityScheduler.cs b/src/Speckle.Sdk/Serialisation/V2/Send/PriorityScheduler.cs
@@ -2,9 +2,7 @@
 
 namespace Speckle.Sdk.Serialisation.V2.Send;
 
-public sealed class PriorityScheduler(ThreadPriority priority, int maximumConcurrencyLevel)
-  : TaskScheduler,
-    IDisposable
+public sealed class PriorityScheduler(ThreadPriority priority, int maximumConcurrencyLevel) : TaskScheduler, IDisposable
 {
   private readonly BlockingCollection<Task> _tasks = new();
   private Thread[]? _threads;

diff --git a/src/Speckle.Sdk/Serialisation/V2/Send/SerializeProcess.cs b/src/Speckle.Sdk/Serialisation/V2/Send/SerializeProcess.cs
@@ -51,11 +51,8 @@ public sealed class SerializeProcess(
   SerializeProcessOptions? options = null
 ) : ChannelSaver<BaseItem>, ISerializeProcess
 {
-  private readonly PriorityScheduler _highest = new( ThreadPriority.Highest, 2);
-  private readonly PriorityScheduler _belowNormal = new(
-    ThreadPriority.BelowNormal,
-    Environment.ProcessorCount * 3
-  );
+  private readonly PriorityScheduler _highest = new(ThreadPriority.Highest, 2);
+  private readonly PriorityScheduler _belowNormal = new(ThreadPriority.BelowNormal, Environment.ProcessorCount * 3);
 
   private readonly SerializeProcessOptions _options = options ?? new(false, false, false, false);
 
@@ -84,7 +81,7 @@ public void Dispose()
 
   public async Task<SerializeProcessResults> Serialize(Base root, CancellationToken cancellationToken)
   {
-    var channelTask = Start( cancellationToken);
+    var channelTask = Start(cancellationToken);
     var findTotalObjectsTask = Task.CompletedTask;
     if (!_options.SkipFindTotalObjects)
     {
@@ -155,12 +152,18 @@ private async Task<Dictionary<Id, NodeInfo>> Traverse(Base obj, bool isEnd, Canc
       if (item.NeedsStorage)
       {
         //just await enqueuing
-        await Task.Factory.StartNew(async () =>
-          {
-            Interlocked.Increment(ref _objectsSerialized);
-            await Save(item, cancellationToken).ConfigureAwait(false);
-          },
-          cancellationToken, TaskCreationOptions.DenyChildAttach, _highest).ConfigureAwait(true);
+        await Task
+          .Factory.StartNew(
+            async () =>
+            {
+              Interlocked.Increment(ref _objectsSerialized);
+              await Save(item, cancellationToken).ConfigureAwait(false);
+            },
+            cancellationToken,
+            TaskCreationOptions.DenyChildAttach,
+            _highest
+          )
+          .ConfigureAwait(true);
       }
 
       if (!currentClosures.ContainsKey(item.Id))

diff --git a/tests/Speckle.Sdk.Serialization.Tests/DetachedTests.cs b/tests/Speckle.Sdk.Serialization.Tests/DetachedTests.cs
@@ -332,7 +332,7 @@ public async Task CanSerialize_New_Detached_With_DataChunks()
 
     var objects = new Dictionary<string, string>();
 
-    using  var process2 = new SerializeProcess(
+    using var process2 = new SerializeProcess(
       null,
       new DummySendCacheManager(objects),
       new DummyServerObjectManager(),
@@ -413,7 +413,7 @@ public async Task CanSerialize_New_Detached_With_DataChunks2()
 
     var objects = new Dictionary<string, string>();
 
-    using  var process2 = new SerializeProcess(
+    using var process2 = new SerializeProcess(
       null,
       new DummySendCacheManager(objects),
       new DummyServerObjectManager(),