fix: update test command

Author: ikesnowy

.github/workflows/ci.yml

@@ -26,5 +26,5 @@ jobs:
       - name: Build
         run: dotnet build src/Cnblogs.DashScope.AI -c Release -p:TargetFrameworks=net8.0
       - name: Test
-        run: dotnet test -p:TargetFrameworks=net8.0
+        run: dotnet test test/Cnblogs.DashScope.AI.UnitTests -c Release -p:TargetFrameworks=net8.0 && dotnet test test/Cnblogs.DashScope.Sdk.UnitTests -c Release -p:TargetFrameworks=net8.0
 

src/Cnblogs.DashScope.Core/DashScopeClientCore.cs

@@ -552,28 +552,31 @@ private async IAsyncEnumerable<TResponse> StreamAsync<TResponse>(
             HttpCompletionOption.ResponseHeadersRead,
             cancellationToken);
         using StreamReader reader = new(await response.Content.ReadAsStreamAsync(cancellationToken), Encoding.UTF8);
-        while (!reader.EndOfStream)
+        while (await reader.ReadLineAsync() is { } line)
         {
             if (cancellationToken.IsCancellationRequested)
+            {
                 throw new TaskCanceledException();
+            }
+
+            if (line.StartsWith("data:") == false)
+            {
+                continue;
+            }
 
-            var line = await reader.ReadLineAsync();
-            if (line != null && line.StartsWith("data:"))
+            var data = line["data:".Length..];
+            if (data.StartsWith("{\"code\":"))
             {
-                var data = line["data:".Length..];
-                if (data.StartsWith("{\"code\":"))
-                {
-                    var error =
-                        JsonSerializer.Deserialize<DashScopeError>(data, DashScopeDefaults.SerializationOptions)!;
-                    throw new DashScopeException(
-                        message.RequestUri?.ToString(),
-                        (int)response.StatusCode,
-                        error,
-                        error.Message);
-                }
-
-                yield return JsonSerializer.Deserialize<TResponse>(data, DashScopeDefaults.SerializationOptions)!;
+                var error =
+                    JsonSerializer.Deserialize<DashScopeError>(data, DashScopeDefaults.SerializationOptions)!;
+                throw new DashScopeException(
+                    message.RequestUri?.ToString(),
+                    (int)response.StatusCode,
+                    error,
+                    error.Message);
             }
+
+            yield return JsonSerializer.Deserialize<TResponse>(data, DashScopeDefaults.SerializationOptions)!;
         }
     }