Fixed internal type serialization

Azure · May 14, 2020 · 5adc575 · 5adc575
1 parent 4d618b6
commit 5adc575
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 5 deletions.
diff --git a/Microsoft.Azure.Cosmos/src/Query/v3Query/ReadFeedResponse.cs b/Microsoft.Azure.Cosmos/src/Query/v3Query/ReadFeedResponse.cs
@@ -4,11 +4,7 @@
 namespace Microsoft.Azure.Cosmos
 {
  using System.Collections.Generic;
- using System.IO;
  using System.Net;
- using Microsoft.Azure.Cosmos.CosmosElements;
- using Microsoft.Azure.Cosmos.Json;
- using Microsoft.Azure.Cosmos.Serializer;
 
  internal class ReadFeedResponse<T> : FeedResponse<T>
  {

diff --git a/Microsoft.Azure.Cosmos/src/Serializer/CosmosFeedResponseSerializer.cs b/Microsoft.Azure.Cosmos/src/Serializer/CosmosFeedResponseSerializer.cs
@@ -37,7 +37,7 @@ internal static IReadOnlyList<T> FromFeedResponseStream<T>(
  using (MemoryStream stream = GetStreamWithoutServiceEnvelope(
  streamWithServiceEnvelope))
  {
- return serializerCore.FromStream<List<T>>(stream);
+ return serializerCore.FromFeedStream<T>(stream);
  }
  }
  }

diff --git a/Microsoft.Azure.Cosmos/src/Serializer/CosmosSerializerCore.cs b/Microsoft.Azure.Cosmos/src/Serializer/CosmosSerializerCore.cs
@@ -5,6 +5,7 @@
 namespace Microsoft.Azure.Cosmos
 {
  using System;
+ using System.Collections.Generic;
  using System.IO;
  using Microsoft.Azure.Cosmos.Query.Core;
  using Microsoft.Azure.Cosmos.Query.Core.QueryPlan;
@@ -61,6 +62,12 @@ internal T FromStream<T>(Stream stream)
  return serializer.FromStream<T>(stream);
  }
 
+ internal IReadOnlyList<T> FromFeedStream<T>(Stream stream)
+ {
+ CosmosSerializer serializer = this.GetSerializer<T>();
+ return serializer.FromStream<List<T>>(stream);
+ }
+
  internal Stream ToStream<T>(T input)
  {
  CosmosSerializer serializer = this.GetSerializer<T>();