format

specklesystems · Oct 25, 2024 · fa9fe32 · fa9fe32
1 parent acf420a
commit fa9fe32
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 8 deletions.
diff --git a/src/Speckle.Sdk.Dependencies/Serialization/ChannelLoader.cs b/src/Speckle.Sdk.Dependencies/Serialization/ChannelLoader.cs
@@ -6,24 +6,28 @@ public abstract class ChannelLoader
 {
   private const int HTTP_ID_CHUNK_SIZE = 500;
   private const int MAX_PARALLELISM_HTTP = 4;
-  
+
   protected async Task GetAndCache(IEnumerable<string> allChildrenIds, CancellationToken cancellationToken = default) =>
     await allChildrenIds
       .ToChannel(cancellationToken: cancellationToken)
       .Pipe(Environment.ProcessorCount, CheckCache, cancellationToken: cancellationToken)
       .Filter(x => x is not null)
       .Batch(HTTP_ID_CHUNK_SIZE)
       .WithTimeout(TimeSpan.FromSeconds(2))
-      .PipeAsync(MAX_PARALLELISM_HTTP, async x => await DownloadAndCache(x).ConfigureAwait(false), -1, false, cancellationToken)
+      .PipeAsync(
+        MAX_PARALLELISM_HTTP,
+        async x => await DownloadAndCache(x).ConfigureAwait(false),
+        -1,
+        false,
+        cancellationToken
+      )
       .Join()
       .ReadAllConcurrently(Environment.ProcessorCount, SaveToCache, cancellationToken)
       .ConfigureAwait(false);
 
-
   public abstract string? CheckCache(string id);
 
   public abstract Task<List<(string, string)>> DownloadAndCache(List<string?> ids);
 
   public abstract void SaveToCache((string, string) x);
-
 }
diff --git a/src/Speckle.Sdk/Serialisation/V2/Receive/ObjectLoader.cs b/src/Speckle.Sdk/Serialisation/V2/Receive/ObjectLoader.cs
@@ -13,7 +13,6 @@ public sealed class ObjectLoader(
   IProgress<ProgressArgs>? progress
 ) : ChannelLoader, IObjectLoader
 {
-
   private int? _allChildrenCount;
   private long _checkCache;
   private long _cached;
@@ -48,8 +47,7 @@ CancellationToken cancellationToken
       .Where(x => !x.StartsWith("blob", StringComparison.Ordinal))
       .ToList();
     _allChildrenCount = allChildrenIds.Count;
-    await GetAndCache(allChildrenIds, cancellationToken)
-      .ConfigureAwait(false);
+    await GetAndCache(allChildrenIds, cancellationToken).ConfigureAwait(false);
 
     //save the root last to shortcut later
     sqLiteCacheManager.SaveObjectSync(rootId, rootJson);

diff --git a/src/Speckle.Sdk/Serialisation/V2/SQLiteCacheManager.cs b/src/Speckle.Sdk/Serialisation/V2/SQLiteCacheManager.cs
@@ -99,7 +99,7 @@ public bool HasObject(string objectId)
     bool rowFound = reader.Read();
     return rowFound;
   }
-  
+
   public void SaveObjectSync(string hash, string serializedObject)
   {
     using var c = new SqliteConnection(_connectionString);