Merge pull request #168 from MihaMarkic/feature/async

Implements IAsyncParseNodeFactory interface

CHANGELOG.md

@@ -7,8 +7,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [1.2.0] - 2024-05-13
+
 ### Added
 
+- Implements IAsyncParseNodeFactory interface which adds async support 
 
 ## [1.1.5] - 2024-04-19
 

src/Microsoft.Kiota.Serialization.Text.csproj

@@ -13,7 +13,7 @@
     <PackageProjectUrl>https://aka.ms/kiota/docs</PackageProjectUrl>
     <EmbedUntrackedSources>true</EmbedUntrackedSources>
     <Deterministic>true</Deterministic>
-    <VersionPrefix>1.1.5</VersionPrefix>
+    <VersionPrefix>1.2.0</VersionPrefix>
     <VersionSuffix></VersionSuffix>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
     <SignAssembly>false</SignAssembly>

src/TextParseNodeFactory.cs

@@ -1,13 +1,15 @@
 using System;
 using System.IO;
+using System.Threading;
+using System.Threading.Tasks;
 using Microsoft.Kiota.Abstractions.Serialization;
 
 namespace Microsoft.Kiota.Serialization.Text;
 
 /// <summary>
-/// The <see cref="IParseNodeFactory"/> implementation for text/plain content types
+/// The <see cref="IAsyncParseNodeFactory"/> implementation for text/plain content types
 /// </summary>
-public class TextParseNodeFactory : IParseNodeFactory
+public class TextParseNodeFactory : IAsyncParseNodeFactory
 {
     /// <inheritdoc />
     public string ValidContentType => "text/plain";
@@ -23,4 +25,18 @@ public IParseNode GetRootParseNode(string contentType, Stream content) {
         var stringContent = reader.ReadToEnd();
         return new TextParseNode(stringContent);
     }
+    /// <inheritdoc />
+    public async Task<IParseNode> GetRootParseNodeAsync(string contentType, Stream content, CancellationToken cancellationToken = default)
+    {
+        if(string.IsNullOrEmpty(contentType))
+            throw new ArgumentNullException(nameof(contentType));
+        else if(!ValidContentType.Equals(contentType, StringComparison.OrdinalIgnoreCase))
+            throw new ArgumentOutOfRangeException($"expected a {ValidContentType} content type");
+
+        _ = content ?? throw new ArgumentNullException(nameof(content));
+
+        using var reader = new StreamReader(content);
+        var stringContent = await reader.ReadToEndAsync().ConfigureAwait(false);
+        return new TextParseNode(stringContent);
+    }
 }