Port of: Azure/azure-cosmosdb-java#312 (#8085)

AzureSDKAutomation · Feb 11, 2020 · 8e6115a · 8e6115a
1 parent ffa0c09
commit 8e6115a
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/...oft-azure-cosmos/src/main/java/com/azure/data/cosmos/internal/query/DocumentProducer.java b/...oft-azure-cosmos/src/main/java/com/azure/data/cosmos/internal/query/DocumentProducer.java
@@ -143,7 +143,7 @@ public DocumentProducer(
 
         this.correlatedActivityId = correlatedActivityId;
 
-        this.feedOptions = feedOptions != null ? feedOptions : new FeedOptions();
+        this.feedOptions = feedOptions != null ? new FeedOptions(feedOptions) : new FeedOptions();
         this.feedOptions.requestContinuation(initialContinuationToken);
         this.lastResponseContinuationToken = initialContinuationToken;
         this.resourceType = resourceType;
@@ -161,9 +161,9 @@ public Flux<DocumentProducerFeedResponse> produceAsync() {
                 .getPaginatedQueryResultAsObservable(
                         feedOptions.requestContinuation(),
                         sourcePartitionCreateRequestFunc,
-                        executeRequestFuncWithRetries, 
-                        resourceType, 
-                        top, 
+                        executeRequestFuncWithRetries,
+                        resourceType,
+                        top,
                         pageSize)
                 .map(rsp -> {
                     lastResponseContinuationToken = rsp.continuationToken();
@@ -220,7 +220,7 @@ private List<DocumentProducer<T>> createReplacingDocumentProducersOnSplit(List<P
         }
         return replacingDocumentProducers;
     }
-    
+
     protected DocumentProducer<T> createChildDocumentProducerOnSplit(
             PartitionKeyRange targetRange,
             String initialContinuationToken) {