diff --git a/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/util/CosmosPagedFlux.java b/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/util/CosmosPagedFlux.java index 12c7dcfbf4b53..10b13e9865951 100644 --- a/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/util/CosmosPagedFlux.java +++ b/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/util/CosmosPagedFlux.java @@ -68,7 +68,6 @@ public final class CosmosPagedFlux extends ContinuablePagedFlux handle(Consumer> feedResponseConsumer) { return new CosmosPagedFlux(this.optionsFluxFunction, feedResponseConsumer); } diff --git a/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/util/CosmosPagedIterable.java b/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/util/CosmosPagedIterable.java index 775875420f913..50166a46363e2 100644 --- a/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/util/CosmosPagedIterable.java +++ b/sdk/cosmos/azure-cosmos/src/main/java/com/azure/cosmos/util/CosmosPagedIterable.java @@ -40,7 +40,6 @@ public final class CosmosPagedIterable extends ContinuablePagedIterable handle(Consumer> feedResponseConsumer) { CosmosPagedFlux cosmosPagedFlux = this.cosmosPagedFlux.handle(feedResponseConsumer); return new CosmosPagedIterable<>(cosmosPagedFlux);