use pool and more ValueTask

src/Speckle.Sdk/Serialisation/SpeckleObjectDeserializer.cs

@@ -16,7 +16,7 @@ public sealed class SpeckleObjectDeserializer
   private readonly object _callbackLock = new();
   private readonly object?[] _invokeNull = [null];
 
-  // id -> Base if already deserialized or id -> Task<object> if was handled by a bg thread
+  // id -> Base if already deserialized or id -> ValueTask<object> if was handled by a bg thread
   private ConcurrentDictionary<string, object?>? _deserializedObjects;
 
   /// <summary>
@@ -45,7 +45,7 @@ public sealed class SpeckleObjectDeserializer
   /// <exception cref="ArgumentNullException"><paramref name="rootObjectJson"/> was null</exception>
   /// <exception cref="SpeckleDeserializeException"><paramref name="rootObjectJson"/> cannot be deserialised to type <see cref="Base"/></exception>
   // /// <exception cref="TransportException"><see cref="ReadTransport"/> did not contain the required json objects (closures)</exception>
-  public async Task<Base> DeserializeAsync(string rootObjectJson)
+  public async ValueTask<Base> DeserializeAsync(string rootObjectJson)
   {
     if (_isBusy)
     {
@@ -68,7 +68,7 @@ public sealed class SpeckleObjectDeserializer
     }
   }
 
-  private async Task<object?> DeserializeJsonAsyncInternal(string objectJson)
+  private async ValueTask<object?> DeserializeJsonAsyncInternal(string objectJson)
   {
     if (objectJson is null)
     {
@@ -104,7 +104,7 @@ public sealed class SpeckleObjectDeserializer
   }
 
   //this should be buffered
-  private async Task<List<object?>> ReadArrayAsync(JsonReader reader, CancellationToken ct)
+  private async ValueTask<List<object?>> ReadArrayAsync(JsonReader reader, CancellationToken ct)
   {
     reader.Read();
     List<object?> retList = new();
@@ -124,7 +124,7 @@ public sealed class SpeckleObjectDeserializer
     return retList;
   }
 
-  private async Task<object?> ReadObjectAsync(JsonReader reader, CancellationToken ct)
+  private async ValueTask<object?> ReadObjectAsync(JsonReader reader, CancellationToken ct)
   {
     reader.Read();
     Dictionary<string, object?> dict = new();
@@ -180,7 +180,7 @@ public sealed class SpeckleObjectDeserializer
     return Dict2Base(dict);
   }
 
-  private async Task<object?> TryGetDeserializedAsync(string objId)
+  private async ValueTask<object?> TryGetDeserializedAsync(string objId)
   {
     object? deserialized = null;
     _deserializedObjects.NotNull();
@@ -205,6 +205,22 @@ public sealed class SpeckleObjectDeserializer
         _currentCount++;
       }
     }
+    if (deserialized is ValueTask<object> valueTask)
+    {
+      try
+      {
+        deserialized = valueTask.Result;
+      }
+      catch (AggregateException ex)
+      {
+        throw new SpeckleDeserializeException("Failed to deserialize reference object", ex);
+      }
+
+      if (_deserializedObjects.TryAdd(objId, deserialized))
+      {
+        _currentCount++;
+      }
+    }
     if (deserialized != null)
     {
       return deserialized;
@@ -227,7 +243,7 @@ public sealed class SpeckleObjectDeserializer
     return deserialized;
   }
 
-  private async Task<object?> ReadPropertyAsync(JsonReader reader, CancellationToken ct)
+  private async ValueTask<object?> ReadPropertyAsync(JsonReader reader, CancellationToken ct)
   {
     ct.ThrowIfCancellationRequested();
     switch (reader.TokenType)

src/Speckle.Sdk/Serialisation/SpeckleObjectSerializer.cs

@@ -251,7 +251,7 @@ public class SpeckleObjectSerializer
     }
 
     using var writer = new StringWriter();
-    using var jsonWriter = new JsonTextWriter(writer);
+    using var jsonWriter = SpeckleObjectSerializerPool.Instance.GetJsonTextWriter(writer);
     string id = SerializeBaseObject(baseObj, jsonWriter, closure);
     var json = writer.ToString();
 
@@ -275,7 +275,7 @@ public class SpeckleObjectSerializer
 
       ObjectReference objRef = new() { referencedId = id };
       using var writer2 = new StringWriter();
-      using var jsonWriter2 = new JsonTextWriter(writer2);
+      using var jsonWriter2 = SpeckleObjectSerializerPool.Instance.GetJsonTextWriter(writer2);
       SerializeProperty(objRef, jsonWriter2);
       var json2 = writer2.ToString();
       UpdateParentClosures(id);