Implement asynchronous support in ODataJsonLightDeltaWriter

OData · Jun 8, 2021 · 17618c2 · 17618c2
1 parent 3c68c51
commit 17618c2
Show file tree

Hide file tree

Showing 5 changed files with 2,720 additions and 359 deletions.
diff --git a/src/Microsoft.OData.Core/JsonLight/ODataJsonLightDeltaWriter.cs b/src/Microsoft.OData.Core/JsonLight/ODataJsonLightDeltaWriter.cs
@@ -123,7 +123,7 @@ public override void WriteStart(ODataDeltaResourceSet deltaResourceSet)
         /// <returns>A task instance that represents the asynchronous write operation.</returns>
         public override Task WriteStartAsync(ODataDeltaResourceSet deltaResourceSet)
         {
-            return TaskUtils.GetTaskForSynchronousOperation(() => this.resourceWriter.WriteStart(deltaResourceSet));
+            return this.resourceWriter.WriteStartAsync(deltaResourceSet);
         }
 
         /// <summary>
@@ -140,7 +140,7 @@ public override void WriteEnd()
         /// <returns>A task instance that represents the asynchronous write operation.</returns>
         public override Task WriteEndAsync()
         {
-            return TaskUtils.GetTaskForSynchronousOperation(() => this.resourceWriter.WriteEnd());
+            return this.resourceWriter.WriteEndAsync();
         }
 
         /// <summary>
@@ -159,7 +159,7 @@ public override void WriteStart(ODataNestedResourceInfo nestedResourceInfo)
         /// <returns>A task instance that represents the asynchronous write operation.</returns>
         public override Task WriteStartAsync(ODataNestedResourceInfo nestedResourceInfo)
         {
-            return TaskUtils.GetTaskForSynchronousOperation(() => this.resourceWriter.WriteStart(nestedResourceInfo));
+            return this.resourceWriter.WriteStartAsync(nestedResourceInfo);
         }
 
         /// <summary>
@@ -178,7 +178,7 @@ public override void WriteStart(ODataResourceSet expandedResourceSet)
         /// <returns>A task instance that represents the asynchronous write operation.</returns>
         public override Task WriteStartAsync(ODataResourceSet expandedResourceSet)
         {
-            return TaskUtils.GetTaskForSynchronousOperation(() => this.resourceWriter.WriteStart(expandedResourceSet));
+            return this.resourceWriter.WriteStartAsync(expandedResourceSet);
         }
 
         /// <summary>
@@ -197,7 +197,7 @@ public override void WriteStart(ODataResource deltaResource)
         /// <returns>A task instance that represents the asynchronous write operation.</returns>
         public override Task WriteStartAsync(ODataResource deltaResource)
         {
-            return TaskUtils.GetTaskForSynchronousOperation(() => this.resourceWriter.WriteStart(deltaResource));
+            return this.resourceWriter.WriteStartAsync(deltaResource);
         }
 
         /// <summary>
@@ -217,7 +217,7 @@ public override void WriteDeltaDeletedEntry(ODataDeltaDeletedEntry deltaDeletedE
         /// <returns>A task instance that represents the asynchronous write operation.</returns>
         public override Task WriteDeltaDeletedEntryAsync(ODataDeltaDeletedEntry deltaDeletedEntry)
         {
-            return TaskUtils.GetTaskForSynchronousOperation(() => this.resourceWriter.WriteStart(ODataDeltaDeletedEntry.GetDeletedResource(deltaDeletedEntry)));
+            return this.resourceWriter.WriteStartAsync(ODataDeltaDeletedEntry.GetDeletedResource(deltaDeletedEntry));
         }
 
         /// <summary>
@@ -236,7 +236,7 @@ public override void WriteDeltaLink(ODataDeltaLink deltaLink)
         /// <returns>A task instance that represents the asynchronous write operation.</returns>
         public override Task WriteDeltaLinkAsync(ODataDeltaLink deltaLink)
         {
-            return TaskUtils.GetTaskForSynchronousOperation(() => this.resourceWriter.WriteDeltaLink(deltaLink));
+            return this.resourceWriter.WriteDeltaLinkAsync(deltaLink);
         }
 
         /// <summary>
@@ -255,7 +255,7 @@ public override void WriteDeltaDeletedLink(ODataDeltaDeletedLink deltaDeletedLin
         /// <returns>A task instance that represents the asynchronous write operation.</returns>
         public override Task WriteDeltaDeletedLinkAsync(ODataDeltaDeletedLink deltaDeletedLink)
         {
-            return TaskUtils.GetTaskForSynchronousOperation(() => this.resourceWriter.WriteDeltaDeletedLink(deltaDeletedLink));
+            return this.resourceWriter.WriteDeltaDeletedLinkAsync(deltaDeletedLink);
         }
 
         /// <summary>
@@ -290,7 +290,7 @@ void IODataOutputInStreamErrorListener.OnInStreamError()
         /// <inheritdoc/>
         Task IODataOutputInStreamErrorListener.OnInStreamErrorAsync()
         {
-            throw new NotImplementedException();
+            return this.inStreamErrorListener.OnInStreamErrorAsync();
         }
 
         #endregion