reateOrUpdate(resourceGroupName, firewallPolicyName, this.client.subscriptionId(), parameters, apiVersion, this.client.acceptLanguage(), this.client.userAgent())             .flatMap(new Func0<Response<ResponseBody>, Observable<ServiceResponse<FirewallPolicyInner>>>() {                 @Override                 public Observable<ServiceResponse<FirewallPolicyInner>> call(Response<ResponseBody> response) {                     try {                         ServiceResponse<FirewallPolicyInner> clientResponse = 