AzureSDKAutomation · openapi-sdkautomation · Mar 30, 2021
diff --git a/sdk/netapp/azure-resourcemanager-netapp/CHANGELOG.md b/sdk/netapp/azure-resourcemanager-netapp/CHANGELOG.md
@@ -1,7 +1,8 @@
 # Release History
 
-## 1.0.0-beta.3 (Unreleased)
+## 1.0.0-beta.1 (2021-03-30)
 
+- Azure Resource Manager NetAppFiles client library for Java. This package contains Microsoft Azure SDK for NetAppFiles Management SDK. Microsoft NetApp Files Azure Resource Provider specification. Package tag package-netapp-2020-12-01. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ## 1.0.0-beta.2 (2021-03-15)
 

diff --git a/sdk/netapp/azure-resourcemanager-netapp/README.md b/sdk/netapp/azure-resourcemanager-netapp/README.md
@@ -32,7 +32,7 @@ Various documentation is available to help you get started
 <dependency>
     <groupId>com.azure.resourcemanager</groupId>
     <artifactId>azure-resourcemanager-netapp</artifactId>
-    <version>1.0.0-beta.2</version>
+    <version>1.0.0-beta.3</version>
 </dependency>
 ```
 [//]: # ({x-version-update-end})

diff --git a/...urcemanager-netapp/src/main/java/com/azure/resourcemanager/netapp/NetAppFilesManager.java b/...urcemanager-netapp/src/main/java/com/azure/resourcemanager/netapp/NetAppFilesManager.java
@@ -202,7 +202,7 @@ public NetAppFilesManager authenticate(TokenCredential credential, AzureProfile
                 .append("-")
                 .append("com.azure.resourcemanager.netapp")
                 .append("/")
-                .append("1.0.0-beta.2");
+                .append("1.0.0-beta.1");
             if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
                 userAgentBuilder
                     .append(" (")

diff --git a/...ager-netapp/src/main/java/com/azure/resourcemanager/netapp/fluent/models/BackupInner.java b/...ager-netapp/src/main/java/com/azure/resourcemanager/netapp/fluent/models/BackupInner.java
@@ -8,6 +8,7 @@
 import com.azure.core.annotation.JsonFlatten;
 import com.azure.core.management.ProxyResource;
 import com.azure.core.util.logging.ClientLogger;
+import com.azure.resourcemanager.netapp.models.BackupType;
 import com.fasterxml.jackson.annotation.JsonIgnore;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import java.time.OffsetDateTime;
@@ -55,10 +56,10 @@ public class BackupInner extends ProxyResource {
     private String label;
 
     /*
-     * Type of backup adhoc or scheduled
+     * Type of backup Manual or Scheduled
      */
     @JsonProperty(value = "properties.backupType", access = JsonProperty.Access.WRITE_ONLY)
-    private String backupType;
+    private BackupType backupType;
 
     /*
      * Failure reason
@@ -149,11 +150,11 @@ public BackupInner withLabel(String label) {
     }
 
     /**
-     * Get the backupType property: Type of backup adhoc or scheduled.
+     * Get the backupType property: Type of backup Manual or Scheduled.
      *
      * @return the backupType value.
      */
-    public String backupType() {
+    public BackupType backupType() {
         return this.backupType;
     }
 

diff --git a/...ager-netapp/src/main/java/com/azure/resourcemanager/netapp/fluent/models/VolumeInner.java b/...ager-netapp/src/main/java/com/azure/resourcemanager/netapp/fluent/models/VolumeInner.java
@@ -57,7 +57,7 @@ public class VolumeInner extends Resource {
     private VolumePropertiesExportPolicy exportPolicy;
 
     /*
-     * Set of protocol types, default NFSv3, CIFS fro SMB protocol
+     * Set of protocol types, default NFSv3, CIFS for SMB protocol
      */
     @JsonProperty(value = "properties.protocolTypes")
     private List<String> protocolTypes;
@@ -265,7 +265,7 @@ public VolumeInner withExportPolicy(VolumePropertiesExportPolicy exportPolicy) {
     }
 
     /**
-     * Get the protocolTypes property: Set of protocol types, default NFSv3, CIFS fro SMB protocol.
+     * Get the protocolTypes property: Set of protocol types, default NFSv3, CIFS for SMB protocol.
      *
      * @return the protocolTypes value.
      */
@@ -274,7 +274,7 @@ public List<String> protocolTypes() {
     }
 
     /**
-     * Set the protocolTypes property: Set of protocol types, default NFSv3, CIFS fro SMB protocol.
+     * Set the protocolTypes property: Set of protocol types, default NFSv3, CIFS for SMB protocol.
      *
      * @param protocolTypes the protocolTypes value to set.
      * @return the VolumeInner object itself.

diff --git a/...c/main/java/com/azure/resourcemanager/netapp/implementation/AccountBackupsClientImpl.java b/...c/main/java/com/azure/resourcemanager/netapp/implementation/AccountBackupsClientImpl.java
@@ -152,7 +152,7 @@ private Mono<Response<BackupsListInner>> listWithResponseAsync(String resourceGr
                             this.client.getApiVersion(),
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -305,7 +305,7 @@ private Mono<Response<BackupInner>> getWithResponseAsync(
                             this.client.getApiVersion(),
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -465,7 +465,7 @@ private Mono<Response<Flux<ByteBuffer>>> deleteWithResponseAsync(
                             backupName,
                             this.client.getApiVersion(),
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...app/src/main/java/com/azure/resourcemanager/netapp/implementation/AccountsClientImpl.java b/...app/src/main/java/com/azure/resourcemanager/netapp/implementation/AccountsClientImpl.java
@@ -202,7 +202,7 @@ private Mono<PagedResponse<NetAppAccountInner>> listByResourceGroupSinglePageAsy
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -361,7 +361,7 @@ private Mono<Response<NetAppAccountInner>> getByResourceGroupWithResponseAsync(
                             this.client.getApiVersion(),
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -517,7 +517,7 @@ private Mono<Response<Flux<ByteBuffer>>> createOrUpdateWithResponseAsync(
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -768,7 +768,7 @@ private Mono<Response<Flux<ByteBuffer>>> deleteWithResponseAsync(String resource
                             accountName,
                             this.client.getApiVersion(),
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1000,7 +1000,7 @@ private Mono<Response<Flux<ByteBuffer>>> updateWithResponseAsync(
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1240,7 +1240,7 @@ private Mono<PagedResponse<NetAppAccountInner>> listNextSinglePageAsync(String n
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...ager-netapp/src/main/java/com/azure/resourcemanager/netapp/implementation/BackupImpl.java b/...ager-netapp/src/main/java/com/azure/resourcemanager/netapp/implementation/BackupImpl.java
@@ -9,6 +9,7 @@
 import com.azure.resourcemanager.netapp.fluent.models.BackupInner;
 import com.azure.resourcemanager.netapp.models.Backup;
 import com.azure.resourcemanager.netapp.models.BackupPatch;
+import com.azure.resourcemanager.netapp.models.BackupType;
 import java.time.OffsetDateTime;
 import java.util.Map;
 
@@ -53,7 +54,7 @@ public String label() {
         return this.innerModel().label();
     }
 
-    public String backupType() {
+    public BackupType backupType() {
         return this.innerModel().backupType();
     }
 

diff --git a/...c/main/java/com/azure/resourcemanager/netapp/implementation/BackupPoliciesClientImpl.java b/...c/main/java/com/azure/resourcemanager/netapp/implementation/BackupPoliciesClientImpl.java
@@ -198,7 +198,7 @@ private Mono<PagedResponse<BackupPolicyInner>> listSinglePageAsync(String resour
                 res ->
                     new PagedResponseBase<>(
                         res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -364,7 +364,7 @@ private Mono<Response<BackupPolicyInner>> getWithResponseAsync(
                             this.client.getApiVersion(),
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -535,7 +535,7 @@ private Mono<Response<Flux<ByteBuffer>>> createWithResponseAsync(
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -838,7 +838,7 @@ private Mono<Response<BackupPolicyInner>> updateWithResponseAsync(
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1020,7 +1020,7 @@ private Mono<Response<Flux<ByteBuffer>>> deleteWithResponseAsync(
                             backupPolicyName,
                             this.client.getApiVersion(),
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...tapp/src/main/java/com/azure/resourcemanager/netapp/implementation/BackupsClientImpl.java b/...tapp/src/main/java/com/azure/resourcemanager/netapp/implementation/BackupsClientImpl.java
@@ -218,7 +218,7 @@ private Mono<PagedResponse<BackupInner>> listSinglePageAsync(
                 res ->
                     new PagedResponseBase<>(
                         res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -416,7 +416,7 @@ private Mono<Response<BackupInner>> getWithResponseAsync(
                             this.client.getApiVersion(),
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -628,7 +628,7 @@ private Mono<Response<Flux<ByteBuffer>>> createWithResponseAsync(
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -999,7 +999,7 @@ private Mono<Response<Flux<ByteBuffer>>> updateWithResponseAsync(
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1398,7 +1398,7 @@ private Mono<Response<Flux<ByteBuffer>>> deleteWithResponseAsync(
                             backupName,
                             this.client.getApiVersion(),
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/.../main/java/com/azure/resourcemanager/netapp/implementation/NetAppResourcesClientImpl.java b/.../main/java/com/azure/resourcemanager/netapp/implementation/NetAppResourcesClientImpl.java
@@ -144,7 +144,7 @@ private Mono<Response<CheckAvailabilityResponseInner>> checkNameAvailabilityWith
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -296,7 +296,7 @@ private Mono<Response<CheckAvailabilityResponseInner>> checkFilePathAvailability
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -449,7 +449,7 @@ private Mono<Response<CheckAvailabilityResponseInner>> checkQuotaAvailabilityWit
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...p/src/main/java/com/azure/resourcemanager/netapp/implementation/OperationsClientImpl.java b/...p/src/main/java/com/azure/resourcemanager/netapp/implementation/OperationsClientImpl.java
@@ -92,7 +92,7 @@ private Mono<PagedResponse<OperationInner>> listSinglePageAsync() {
                 res ->
                     new PagedResponseBase<>(
                         res.getRequest(), res.getStatusCode(), res.getHeaders(), res.getValue().value(), null, null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**

diff --git a/...netapp/src/main/java/com/azure/resourcemanager/netapp/implementation/PoolsClientImpl.java b/...netapp/src/main/java/com/azure/resourcemanager/netapp/implementation/PoolsClientImpl.java
@@ -212,7 +212,7 @@ private Mono<PagedResponse<CapacityPoolInner>> listSinglePageAsync(String resour
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -385,7 +385,7 @@ private Mono<Response<CapacityPoolInner>> getWithResponseAsync(
                             this.client.getApiVersion(),
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -554,7 +554,7 @@ private Mono<Response<Flux<ByteBuffer>>> createOrUpdateWithResponseAsync(
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -835,7 +835,7 @@ private Mono<Response<Flux<ByteBuffer>>> updateWithResponseAsync(
                             body,
                             accept,
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1106,7 +1106,7 @@ private Mono<Response<Flux<ByteBuffer>>> deleteWithResponseAsync(
                             poolName,
                             this.client.getApiVersion(),
                             context))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**
@@ -1336,7 +1336,7 @@ private Mono<PagedResponse<CapacityPoolInner>> listNextSinglePageAsync(String ne
                         res.getValue().value(),
                         res.getValue().nextLink(),
                         null))
-            .subscriberContext(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext())));
+            .contextWrite(context -> context.putAll(FluxUtil.toReactorContext(this.client.getContext()).readOnly()));
     }
 
     /**