public final class com.microsoft.azure.AzureClient extends com.microsoft.azure.AzureServiceClient
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: com.microsoft.azure.AzureClient
  super_class: com.microsoft.azure.AzureServiceClient
{
  private int longRunningOperationRetryTimeout;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private final java.lang.String serviceClientUserAgent;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public void <init>(com.microsoft.azure.AzureServiceClient);
    descriptor: (Lcom/microsoft/azure/AzureServiceClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.AzureServiceClient serviceClient
         0: .line 51
            aload 0 /* this */
            aload 1 /* serviceClient */
            invokevirtual com.microsoft.azure.AzureServiceClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokespecial com.microsoft.azure.AzureServiceClient.<init>:(Lcom/microsoft/rest/RestClient;)V
         1: .line 38
            aload 0 /* this */
            iconst_m1
            putfield com.microsoft.azure.AzureClient.longRunningOperationRetryTimeout:I
         2: .line 52
            aload 0 /* this */
            aload 1 /* serviceClient */
            invokevirtual com.microsoft.azure.AzureServiceClient.userAgent:()Ljava/lang/String;
            putfield com.microsoft.azure.AzureClient.serviceClientUserAgent:Ljava/lang/String;
         3: .line 53
            return
        end local 1 // com.microsoft.azure.AzureServiceClient serviceClient
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    4     0           this  Lcom/microsoft/azure/AzureClient;
            0    4     1  serviceClient  Lcom/microsoft/azure/AzureServiceClient;
    MethodParameters:
               Name  Flags
      serviceClient  

  public java.lang.Integer longRunningOperationRetryTimeout();
    descriptor: ()Ljava/lang/Integer;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // com.microsoft.azure.AzureClient this
         0: .line 61
            aload 0 /* this */
            getfield com.microsoft.azure.AzureClient.longRunningOperationRetryTimeout:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            areturn
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/microsoft/azure/AzureClient;

  public void setLongRunningOperationRetryTimeout(int);
    descriptor: (I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // int longRunningOperationRetryTimeout
         0: .line 71
            iload 1 /* longRunningOperationRetryTimeout */
            ifge 2
         1: .line 72
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Invalid timeout for long running operations : "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 1 /* longRunningOperationRetryTimeout */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 74
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iload 1 /* longRunningOperationRetryTimeout */
            putfield com.microsoft.azure.AzureClient.longRunningOperationRetryTimeout:I
         3: .line 75
            return
        end local 1 // int longRunningOperationRetryTimeout
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot                              Name  Signature
            0    4     0                              this  Lcom/microsoft/azure/AzureClient;
            0    4     1  longRunningOperationRetryTimeout  I
    MethodParameters:
                                  Name  Flags
      longRunningOperationRetryTimeout  

  private <T> com.microsoft.rest.ServiceResponse<T> getPutOrPatchResult(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, java.lang.reflect.Type);
    descriptor: (Lrx/Observable;Ljava/lang/reflect/Type;)Lcom/microsoft/rest/ServiceResponse;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 90
            aload 0 /* this */
            aload 1 /* observable */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.getPutOrPatchResultAsync:(Lrx/Observable;Ljava/lang/reflect/Type;)Lrx/Observable;
            astore 3 /* asyncObservable */
        start local 3 // rx.Observable asyncObservable
         1: .line 91
            aload 3 /* asyncObservable */
            invokevirtual rx.Observable.toBlocking:()Lrx/observables/BlockingObservable;
            invokevirtual rx.observables.BlockingObservable.last:()Ljava/lang/Object;
            checkcast com.microsoft.rest.ServiceResponse
            areturn
        end local 3 // rx.Observable asyncObservable
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    2     0             this  Lcom/microsoft/azure/AzureClient;
            0    2     1       observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    2     2     resourceType  Ljava/lang/reflect/Type;
            1    2     3  asyncObservable  Lrx/Observable<Lcom/microsoft/rest/ServiceResponse<TT;>;>;
    Exceptions:
      throws com.microsoft.azure.CloudException, java.lang.InterruptedException, java.io.IOException
    Signature: <T:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Ljava/lang/reflect/Type;)Lcom/microsoft/rest/ServiceResponse<TT;>;
    MethodParameters:
              Name  Flags
      observable    
      resourceType  

  public <T, THeader> com.microsoft.rest.ServiceResponseWithHeaders<T, THeader> getPutOrPatchResultWithHeaders(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, java.lang.reflect.Type, java.lang.Class<THeader>);
    descriptor: (Lrx/Observable;Ljava/lang/reflect/Type;Ljava/lang/Class;)Lcom/microsoft/rest/ServiceResponseWithHeaders;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // java.lang.reflect.Type resourceType
        start local 3 // java.lang.Class headerType
         0: .line 109
            aload 0 /* this */
            aload 1 /* observable */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.getPutOrPatchResult:(Lrx/Observable;Ljava/lang/reflect/Type;)Lcom/microsoft/rest/ServiceResponse;
            astore 4 /* bodyResponse */
        start local 4 // com.microsoft.rest.ServiceResponse bodyResponse
         1: .line 110
            new com.microsoft.rest.ServiceResponseWithHeaders
            dup
         2: .line 111
            aload 4 /* bodyResponse */
            invokevirtual com.microsoft.rest.ServiceResponse.body:()Ljava/lang/Object;
         3: .line 112
            aload 0 /* this */
            invokevirtual com.microsoft.azure.AzureClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokevirtual com.microsoft.rest.RestClient.serializerAdapter:()Lcom/microsoft/rest/protocol/SerializerAdapter;
            aload 0 /* this */
            invokevirtual com.microsoft.azure.AzureClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokevirtual com.microsoft.rest.RestClient.serializerAdapter:()Lcom/microsoft/rest/protocol/SerializerAdapter;
            aload 4 /* bodyResponse */
            invokevirtual com.microsoft.rest.ServiceResponse.response:()Lretrofit2/Response;
            invokevirtual retrofit2.Response.headers:()Lokhttp3/Headers;
            invokeinterface com.microsoft.rest.protocol.SerializerAdapter.serialize:(Ljava/lang/Object;)Ljava/lang/String;
            aload 3 /* headerType */
            invokeinterface com.microsoft.rest.protocol.SerializerAdapter.deserialize:(Ljava/lang/String;Ljava/lang/reflect/Type;)Ljava/lang/Object;
         4: .line 113
            aload 4 /* bodyResponse */
            invokevirtual com.microsoft.rest.ServiceResponse.response:()Lretrofit2/Response;
         5: .line 110
            invokespecial com.microsoft.rest.ServiceResponseWithHeaders.<init>:(Ljava/lang/Object;Ljava/lang/Object;Lretrofit2/Response;)V
            areturn
        end local 4 // com.microsoft.rest.ServiceResponse bodyResponse
        end local 3 // java.lang.Class headerType
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    6     0          this  Lcom/microsoft/azure/AzureClient;
            0    6     1    observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    6     2  resourceType  Ljava/lang/reflect/Type;
            0    6     3    headerType  Ljava/lang/Class<TTHeader;>;
            1    6     4  bodyResponse  Lcom/microsoft/rest/ServiceResponse<TT;>;
    Exceptions:
      throws com.microsoft.azure.CloudException, java.lang.InterruptedException, java.io.IOException
    Signature: <T:Ljava/lang/Object;THeader:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Ljava/lang/reflect/Type;Ljava/lang/Class<TTHeader;>;)Lcom/microsoft/rest/ServiceResponseWithHeaders<TT;TTHeader;>;
    MethodParameters:
              Name  Flags
      observable    
      resourceType  
      headerType    

  public <T> rx.Observable<com.microsoft.rest.ServiceResponse<T>> getPutOrPatchResultAsync(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, java.lang.reflect.Type);
    descriptor: (Lrx/Observable;Ljava/lang/reflect/Type;)Lrx/Observable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 127
            aload 0 /* this */
            aload 1 /* observable */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.beginPutOrPatchAsync:(Lrx/Observable;Ljava/lang/reflect/Type;)Lrx/Single;
         1: .line 128
            invokevirtual rx.Single.toObservable:()Lrx/Observable;
         2: .line 129
            new com.microsoft.azure.AzureClient$1
            dup
            aload 0 /* this */
            invokespecial com.microsoft.azure.AzureClient$1.<init>:(Lcom/microsoft/azure/AzureClient;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         3: .line 140
            new com.microsoft.azure.AzureClient$2
            dup
            aload 0 /* this */
            aload 2 /* resourceType */
            invokespecial com.microsoft.azure.AzureClient$2.<init>:(Lcom/microsoft/azure/AzureClient;Ljava/lang/reflect/Type;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         4: .line 146
            invokevirtual rx.Observable.last:()Lrx/Observable;
         5: .line 147
            new com.microsoft.azure.AzureClient$3
            dup
            aload 0 /* this */
            invokespecial com.microsoft.azure.AzureClient$3.<init>:(Lcom/microsoft/azure/AzureClient;)V
            invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
         6: .line 127
            areturn
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    7     0          this  Lcom/microsoft/azure/AzureClient;
            0    7     1    observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    7     2  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Ljava/lang/reflect/Type;)Lrx/Observable<Lcom/microsoft/rest/ServiceResponse<TT;>;>;
    MethodParameters:
              Name  Flags
      observable    
      resourceType  final

  public <T> rx.Single<com.microsoft.azure.PollingState<T>> beginPutOrPatchAsync(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, java.lang.reflect.Type);
    descriptor: (Lrx/Observable;Ljava/lang/reflect/Type;)Lrx/Single;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 169
            aload 1 /* observable */
            new com.microsoft.azure.AzureClient$4
            dup
            aload 0 /* this */
            aload 2 /* resourceType */
            invokespecial com.microsoft.azure.AzureClient$4.<init>:(Lcom/microsoft/azure/AzureClient;Ljava/lang/reflect/Type;)V
            invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
         1: .line 186
            invokevirtual rx.Observable.toSingle:()Lrx/Single;
         2: .line 169
            areturn
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lcom/microsoft/azure/AzureClient;
            0    3     1    observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    3     2  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Ljava/lang/reflect/Type;)Lrx/Single<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      observable    
      resourceType  final

  private <T> rx.Single<com.microsoft.azure.PollingState<T>> pollPutOrPatchSingleAsync(com.microsoft.azure.PollingState<T>, java.lang.reflect.Type);
    descriptor: (Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)Lrx/Single;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 203
            aload 1 /* pollingState */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.PollingState.withResourceType:(Ljava/lang/reflect/Type;)Lcom/microsoft/azure/PollingState;
            pop
         1: .line 204
            aload 1 /* pollingState */
            aload 0 /* this */
            invokevirtual com.microsoft.azure.AzureClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokevirtual com.microsoft.rest.RestClient.serializerAdapter:()Lcom/microsoft/rest/protocol/SerializerAdapter;
            invokevirtual com.microsoft.azure.PollingState.withSerializerAdapter:(Lcom/microsoft/rest/protocol/SerializerAdapter;)Lcom/microsoft/azure/PollingState;
            pop
         2: .line 205
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.isStatusTerminal:()Z
            ifeq 6
         3: .line 206
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.isStatusSucceeded:()Z
            ifeq 5
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.resource:()Ljava/lang/Object;
            ifnonnull 5
         4: .line 207
            aload 0 /* this */
            aload 1 /* pollingState */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.putOrPatchResourceUri:()Ljava/lang/String;
            invokevirtual com.microsoft.azure.AzureClient.updateStateFromGetResourceOperationAsync:(Lcom/microsoft/azure/PollingState;Ljava/lang/String;)Lrx/Observable;
            invokevirtual rx.Observable.toSingle:()Lrx/Single;
            areturn
         5: .line 209
      StackMap locals:
      StackMap stack:
            aload 1 /* pollingState */
            invokestatic rx.Single.just:(Ljava/lang/Object;)Lrx/Single;
            areturn
         6: .line 211
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* pollingState */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.putOrPatchResourceUri:()Ljava/lang/String;
            invokevirtual com.microsoft.azure.AzureClient.putOrPatchPollingDispatcher:(Lcom/microsoft/azure/PollingState;Ljava/lang/String;)Lrx/Observable;
         7: .line 212
            new com.microsoft.azure.AzureClient$5
            dup
            aload 0 /* this */
            invokespecial com.microsoft.azure.AzureClient$5.<init>:(Lcom/microsoft/azure/AzureClient;)V
            invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
         8: .line 219
            new com.microsoft.azure.AzureClient$6
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$6.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         9: .line 228
            invokevirtual rx.Observable.toSingle:()Lrx/Single;
        10: .line 211
            areturn
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   11     0          this  Lcom/microsoft/azure/AzureClient;
            0   11     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
            0   11     2  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;Ljava/lang/reflect/Type;)Lrx/Single<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final
      resourceType  final

  private <T> rx.Observable<com.microsoft.azure.PollingState<T>> pollPutOrPatchAsync(com.microsoft.azure.PollingState<T>, java.lang.reflect.Type);
    descriptor: (Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 244
            aload 1 /* pollingState */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.PollingState.withResourceType:(Ljava/lang/reflect/Type;)Lcom/microsoft/azure/PollingState;
            pop
         1: .line 245
            aload 1 /* pollingState */
            aload 0 /* this */
            invokevirtual com.microsoft.azure.AzureClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokevirtual com.microsoft.rest.RestClient.serializerAdapter:()Lcom/microsoft/rest/protocol/SerializerAdapter;
            invokevirtual com.microsoft.azure.PollingState.withSerializerAdapter:(Lcom/microsoft/rest/protocol/SerializerAdapter;)Lcom/microsoft/azure/PollingState;
            pop
         2: .line 247
            iconst_1
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokestatic rx.Observable.just:(Ljava/lang/Object;)Lrx/Observable;
         3: .line 248
            new com.microsoft.azure.AzureClient$7
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            aload 2 /* resourceType */
            invokespecial com.microsoft.azure.AzureClient$7.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         4: .line 253
            new com.microsoft.azure.AzureClient$8
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$8.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.repeatWhen:(Lrx/functions/Func1;)Lrx/Observable;
         5: .line 264
            new com.microsoft.azure.AzureClient$9
            dup
            aload 0 /* this */
            invokespecial com.microsoft.azure.AzureClient$9.<init>:(Lcom/microsoft/azure/AzureClient;)V
            invokevirtual rx.Observable.retryWhen:(Lrx/functions/Func1;)Lrx/Observable;
         6: .line 277
            new com.microsoft.azure.AzureClient$10
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$10.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.takeUntil:(Lrx/functions/Func1;)Lrx/Observable;
         7: .line 247
            areturn
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    8     0          this  Lcom/microsoft/azure/AzureClient;
            0    8     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
            0    8     2  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;Ljava/lang/reflect/Type;)Lrx/Observable<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final
      resourceType  final

  public <T, THeader> rx.Observable<com.microsoft.rest.ServiceResponseWithHeaders<T, THeader>> getPutOrPatchResultWithHeadersAsync(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, java.lang.reflect.Type, java.lang.Class<THeader>);
    descriptor: (Lrx/Observable;Ljava/lang/reflect/Type;Ljava/lang/Class;)Lrx/Observable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // java.lang.reflect.Type resourceType
        start local 3 // java.lang.Class headerType
         0: .line 298
            aload 0 /* this */
            aload 1 /* observable */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.getPutOrPatchResultAsync:(Lrx/Observable;Ljava/lang/reflect/Type;)Lrx/Observable;
            astore 4 /* bodyResponse */
        start local 4 // rx.Observable bodyResponse
         1: .line 299
            aload 4 /* bodyResponse */
         2: .line 300
            new com.microsoft.azure.AzureClient$11
            dup
            aload 0 /* this */
            aload 3 /* headerType */
            invokespecial com.microsoft.azure.AzureClient$11.<init>:(Lcom/microsoft/azure/AzureClient;Ljava/lang/Class;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         3: .line 299
            areturn
        end local 4 // rx.Observable bodyResponse
        end local 3 // java.lang.Class headerType
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    4     0          this  Lcom/microsoft/azure/AzureClient;
            0    4     1    observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    4     2  resourceType  Ljava/lang/reflect/Type;
            0    4     3    headerType  Ljava/lang/Class<TTHeader;>;
            1    4     4  bodyResponse  Lrx/Observable<Lcom/microsoft/rest/ServiceResponse<TT;>;>;
    Signature: <T:Ljava/lang/Object;THeader:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Ljava/lang/reflect/Type;Ljava/lang/Class<TTHeader;>;)Lrx/Observable<Lcom/microsoft/rest/ServiceResponseWithHeaders<TT;TTHeader;>;>;
    MethodParameters:
              Name  Flags
      observable    
      resourceType  
      headerType    final

  private <T> com.microsoft.rest.ServiceResponse<T> getPostOrDeleteResult(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, java.lang.reflect.Type);
    descriptor: (Lrx/Observable;Ljava/lang/reflect/Type;)Lcom/microsoft/rest/ServiceResponse;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 328
            aload 0 /* this */
            aload 1 /* observable */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.getPostOrDeleteResultAsync:(Lrx/Observable;Ljava/lang/reflect/Type;)Lrx/Observable;
            astore 3 /* asyncObservable */
        start local 3 // rx.Observable asyncObservable
         1: .line 329
            aload 3 /* asyncObservable */
            invokevirtual rx.Observable.toBlocking:()Lrx/observables/BlockingObservable;
            invokevirtual rx.observables.BlockingObservable.last:()Ljava/lang/Object;
            checkcast com.microsoft.rest.ServiceResponse
            areturn
        end local 3 // rx.Observable asyncObservable
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    2     0             this  Lcom/microsoft/azure/AzureClient;
            0    2     1       observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    2     2     resourceType  Ljava/lang/reflect/Type;
            1    2     3  asyncObservable  Lrx/Observable<Lcom/microsoft/rest/ServiceResponse<TT;>;>;
    Exceptions:
      throws com.microsoft.azure.CloudException, java.lang.InterruptedException, java.io.IOException
    Signature: <T:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Ljava/lang/reflect/Type;)Lcom/microsoft/rest/ServiceResponse<TT;>;
    MethodParameters:
              Name  Flags
      observable    
      resourceType  

  public <T, THeader> com.microsoft.rest.ServiceResponseWithHeaders<T, THeader> getPostOrDeleteResultWithHeaders(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, java.lang.reflect.Type, java.lang.Class<THeader>);
    descriptor: (Lrx/Observable;Ljava/lang/reflect/Type;Ljava/lang/Class;)Lcom/microsoft/rest/ServiceResponseWithHeaders;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // java.lang.reflect.Type resourceType
        start local 3 // java.lang.Class headerType
         0: .line 347
            aload 0 /* this */
            aload 1 /* observable */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.getPostOrDeleteResult:(Lrx/Observable;Ljava/lang/reflect/Type;)Lcom/microsoft/rest/ServiceResponse;
            astore 4 /* bodyResponse */
        start local 4 // com.microsoft.rest.ServiceResponse bodyResponse
         1: .line 348
            new com.microsoft.rest.ServiceResponseWithHeaders
            dup
         2: .line 349
            aload 4 /* bodyResponse */
            invokevirtual com.microsoft.rest.ServiceResponse.body:()Ljava/lang/Object;
         3: .line 350
            aload 0 /* this */
            invokevirtual com.microsoft.azure.AzureClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokevirtual com.microsoft.rest.RestClient.serializerAdapter:()Lcom/microsoft/rest/protocol/SerializerAdapter;
            aload 0 /* this */
            invokevirtual com.microsoft.azure.AzureClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokevirtual com.microsoft.rest.RestClient.serializerAdapter:()Lcom/microsoft/rest/protocol/SerializerAdapter;
            aload 4 /* bodyResponse */
            invokevirtual com.microsoft.rest.ServiceResponse.response:()Lretrofit2/Response;
            invokevirtual retrofit2.Response.headers:()Lokhttp3/Headers;
            invokeinterface com.microsoft.rest.protocol.SerializerAdapter.serialize:(Ljava/lang/Object;)Ljava/lang/String;
            aload 3 /* headerType */
            invokeinterface com.microsoft.rest.protocol.SerializerAdapter.deserialize:(Ljava/lang/String;Ljava/lang/reflect/Type;)Ljava/lang/Object;
         4: .line 351
            aload 4 /* bodyResponse */
            invokevirtual com.microsoft.rest.ServiceResponse.response:()Lretrofit2/Response;
         5: .line 348
            invokespecial com.microsoft.rest.ServiceResponseWithHeaders.<init>:(Ljava/lang/Object;Ljava/lang/Object;Lretrofit2/Response;)V
            areturn
        end local 4 // com.microsoft.rest.ServiceResponse bodyResponse
        end local 3 // java.lang.Class headerType
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    6     0          this  Lcom/microsoft/azure/AzureClient;
            0    6     1    observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    6     2  resourceType  Ljava/lang/reflect/Type;
            0    6     3    headerType  Ljava/lang/Class<TTHeader;>;
            1    6     4  bodyResponse  Lcom/microsoft/rest/ServiceResponse<TT;>;
    Exceptions:
      throws com.microsoft.azure.CloudException, java.lang.InterruptedException, java.io.IOException
    Signature: <T:Ljava/lang/Object;THeader:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Ljava/lang/reflect/Type;Ljava/lang/Class<TTHeader;>;)Lcom/microsoft/rest/ServiceResponseWithHeaders<TT;TTHeader;>;
    MethodParameters:
              Name  Flags
      observable    
      resourceType  
      headerType    

  public <T> rx.Observable<com.microsoft.rest.ServiceResponse<T>> getPostOrDeleteResultAsync(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, java.lang.reflect.Type);
    descriptor: (Lrx/Observable;Ljava/lang/reflect/Type;)Lrx/Observable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 366
            aload 0 /* this */
            aload 1 /* observable */
            getstatic com.microsoft.azure.LongRunningOperationOptions.DEFAULT:Lcom/microsoft/azure/LongRunningOperationOptions;
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.getPostOrDeleteResultAsync:(Lrx/Observable;Lcom/microsoft/azure/LongRunningOperationOptions;Ljava/lang/reflect/Type;)Lrx/Observable;
            areturn
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    1     0          this  Lcom/microsoft/azure/AzureClient;
            0    1     1    observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    1     2  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Ljava/lang/reflect/Type;)Lrx/Observable<Lcom/microsoft/rest/ServiceResponse<TT;>;>;
    MethodParameters:
              Name  Flags
      observable    
      resourceType  final

  public <T> rx.Observable<com.microsoft.rest.ServiceResponse<T>> getPostOrDeleteResultAsync(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, com.microsoft.azure.LongRunningOperationOptions, java.lang.reflect.Type);
    descriptor: (Lrx/Observable;Lcom/microsoft/azure/LongRunningOperationOptions;Ljava/lang/reflect/Type;)Lrx/Observable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=4
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // com.microsoft.azure.LongRunningOperationOptions lroOptions
        start local 3 // java.lang.reflect.Type resourceType
         0: .line 381
            aload 0 /* this */
            aload 1 /* observable */
            aload 2 /* lroOptions */
            aload 3 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.beginPostOrDeleteAsync:(Lrx/Observable;Lcom/microsoft/azure/LongRunningOperationOptions;Ljava/lang/reflect/Type;)Lrx/Single;
         1: .line 382
            invokevirtual rx.Single.toObservable:()Lrx/Observable;
         2: .line 383
            new com.microsoft.azure.AzureClient$12
            dup
            aload 0 /* this */
            invokespecial com.microsoft.azure.AzureClient$12.<init>:(Lcom/microsoft/azure/AzureClient;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         3: .line 394
            new com.microsoft.azure.AzureClient$13
            dup
            aload 0 /* this */
            aload 3 /* resourceType */
            invokespecial com.microsoft.azure.AzureClient$13.<init>:(Lcom/microsoft/azure/AzureClient;Ljava/lang/reflect/Type;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         4: .line 400
            invokevirtual rx.Observable.last:()Lrx/Observable;
         5: .line 401
            new com.microsoft.azure.AzureClient$14
            dup
            aload 0 /* this */
            invokespecial com.microsoft.azure.AzureClient$14.<init>:(Lcom/microsoft/azure/AzureClient;)V
            invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
         6: .line 381
            areturn
        end local 3 // java.lang.reflect.Type resourceType
        end local 2 // com.microsoft.azure.LongRunningOperationOptions lroOptions
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    7     0          this  Lcom/microsoft/azure/AzureClient;
            0    7     1    observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    7     2    lroOptions  Lcom/microsoft/azure/LongRunningOperationOptions;
            0    7     3  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Lcom/microsoft/azure/LongRunningOperationOptions;Ljava/lang/reflect/Type;)Lrx/Observable<Lcom/microsoft/rest/ServiceResponse<TT;>;>;
    MethodParameters:
              Name  Flags
      observable    
      lroOptions    final
      resourceType  final

  public <T> rx.Single<com.microsoft.azure.PollingState<T>> beginPostOrDeleteAsync(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, com.microsoft.azure.LongRunningOperationOptions, java.lang.reflect.Type);
    descriptor: (Lrx/Observable;Lcom/microsoft/azure/LongRunningOperationOptions;Ljava/lang/reflect/Type;)Lrx/Single;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=4, args_size=4
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // com.microsoft.azure.LongRunningOperationOptions lroOptions
        start local 3 // java.lang.reflect.Type resourceType
         0: .line 421
            aload 1 /* observable */
            new com.microsoft.azure.AzureClient$15
            dup
            aload 0 /* this */
            aload 2 /* lroOptions */
            aload 3 /* resourceType */
            invokespecial com.microsoft.azure.AzureClient$15.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/LongRunningOperationOptions;Ljava/lang/reflect/Type;)V
            invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
         1: .line 437
            invokevirtual rx.Observable.toSingle:()Lrx/Single;
         2: .line 421
            areturn
        end local 3 // java.lang.reflect.Type resourceType
        end local 2 // com.microsoft.azure.LongRunningOperationOptions lroOptions
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lcom/microsoft/azure/AzureClient;
            0    3     1    observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    3     2    lroOptions  Lcom/microsoft/azure/LongRunningOperationOptions;
            0    3     3  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Lcom/microsoft/azure/LongRunningOperationOptions;Ljava/lang/reflect/Type;)Lrx/Single<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      observable    
      lroOptions    final
      resourceType  final

  private <T> rx.Single<com.microsoft.azure.PollingState<T>> pollPostOrDeleteSingleAsync(com.microsoft.azure.PollingState<T>, java.lang.reflect.Type);
    descriptor: (Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)Lrx/Single;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 451
            aload 1 /* pollingState */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.PollingState.withResourceType:(Ljava/lang/reflect/Type;)Lcom/microsoft/azure/PollingState;
            pop
         1: .line 452
            aload 1 /* pollingState */
            aload 0 /* this */
            invokevirtual com.microsoft.azure.AzureClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokevirtual com.microsoft.rest.RestClient.serializerAdapter:()Lcom/microsoft/rest/protocol/SerializerAdapter;
            invokevirtual com.microsoft.azure.PollingState.withSerializerAdapter:(Lcom/microsoft/rest/protocol/SerializerAdapter;)Lcom/microsoft/azure/PollingState;
            pop
         2: .line 453
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.isStatusTerminal:()Z
            ifeq 6
         3: .line 454
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.resourcePending:()Z
            ifeq 5
         4: .line 455
            aload 0 /* this */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.AzureClient.updateStateFromLocationHeaderOnPostOrDeleteAsync:(Lcom/microsoft/azure/PollingState;)Lrx/Observable;
            invokevirtual rx.Observable.toSingle:()Lrx/Single;
            areturn
         5: .line 457
      StackMap locals:
      StackMap stack:
            aload 1 /* pollingState */
            invokestatic rx.Single.just:(Ljava/lang/Object;)Lrx/Single;
            areturn
         6: .line 459
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.AzureClient.postOrDeletePollingDispatcher:(Lcom/microsoft/azure/PollingState;)Lrx/Observable;
         7: .line 460
            new com.microsoft.azure.AzureClient$16
            dup
            aload 0 /* this */
            invokespecial com.microsoft.azure.AzureClient$16.<init>:(Lcom/microsoft/azure/AzureClient;)V
            invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
         8: .line 467
            new com.microsoft.azure.AzureClient$17
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$17.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         9: .line 476
            invokevirtual rx.Observable.toSingle:()Lrx/Single;
        10: .line 459
            areturn
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   11     0          this  Lcom/microsoft/azure/AzureClient;
            0   11     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
            0   11     2  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;Ljava/lang/reflect/Type;)Lrx/Single<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final
      resourceType  final

  private <T> rx.Observable<com.microsoft.azure.PollingState<T>> pollPostOrDeleteAsync(com.microsoft.azure.PollingState<T>, java.lang.reflect.Type);
    descriptor: (Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 490
            aload 1 /* pollingState */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.PollingState.withResourceType:(Ljava/lang/reflect/Type;)Lcom/microsoft/azure/PollingState;
            pop
         1: .line 491
            aload 1 /* pollingState */
            aload 0 /* this */
            invokevirtual com.microsoft.azure.AzureClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokevirtual com.microsoft.rest.RestClient.serializerAdapter:()Lcom/microsoft/rest/protocol/SerializerAdapter;
            invokevirtual com.microsoft.azure.PollingState.withSerializerAdapter:(Lcom/microsoft/rest/protocol/SerializerAdapter;)Lcom/microsoft/azure/PollingState;
            pop
         2: .line 493
            iconst_1
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokestatic rx.Observable.just:(Ljava/lang/Object;)Lrx/Observable;
         3: .line 494
            new com.microsoft.azure.AzureClient$18
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            aload 2 /* resourceType */
            invokespecial com.microsoft.azure.AzureClient$18.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         4: .line 499
            new com.microsoft.azure.AzureClient$19
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$19.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.repeatWhen:(Lrx/functions/Func1;)Lrx/Observable;
         5: .line 510
            new com.microsoft.azure.AzureClient$20
            dup
            aload 0 /* this */
            invokespecial com.microsoft.azure.AzureClient$20.<init>:(Lcom/microsoft/azure/AzureClient;)V
            invokevirtual rx.Observable.retryWhen:(Lrx/functions/Func1;)Lrx/Observable;
         6: .line 523
            new com.microsoft.azure.AzureClient$21
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$21.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.takeUntil:(Lrx/functions/Func1;)Lrx/Observable;
         7: .line 493
            areturn
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    8     0          this  Lcom/microsoft/azure/AzureClient;
            0    8     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
            0    8     2  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;Ljava/lang/reflect/Type;)Lrx/Observable<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final
      resourceType  final

  public <T, THeader> rx.Observable<com.microsoft.rest.ServiceResponseWithHeaders<T, THeader>> getPostOrDeleteResultWithHeadersAsync(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, java.lang.reflect.Type, java.lang.Class<THeader>);
    descriptor: (Lrx/Observable;Ljava/lang/reflect/Type;Ljava/lang/Class;)Lrx/Observable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // java.lang.reflect.Type resourceType
        start local 3 // java.lang.Class headerType
         0: .line 544
            aload 0 /* this */
            aload 1 /* observable */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.getPostOrDeleteResultAsync:(Lrx/Observable;Ljava/lang/reflect/Type;)Lrx/Observable;
            astore 4 /* bodyResponse */
        start local 4 // rx.Observable bodyResponse
         1: .line 545
            aload 4 /* bodyResponse */
         2: .line 546
            new com.microsoft.azure.AzureClient$22
            dup
            aload 0 /* this */
            aload 3 /* headerType */
            invokespecial com.microsoft.azure.AzureClient$22.<init>:(Lcom/microsoft/azure/AzureClient;Ljava/lang/Class;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         3: .line 545
            areturn
        end local 4 // rx.Observable bodyResponse
        end local 3 // java.lang.Class headerType
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    4     0          this  Lcom/microsoft/azure/AzureClient;
            0    4     1    observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    4     2  resourceType  Ljava/lang/reflect/Type;
            0    4     3    headerType  Ljava/lang/Class<TTHeader;>;
            1    4     4  bodyResponse  Lrx/Observable<Lcom/microsoft/rest/ServiceResponse<TT;>;>;
    Signature: <T:Ljava/lang/Object;THeader:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Ljava/lang/reflect/Type;Ljava/lang/Class<TTHeader;>;)Lrx/Observable<Lcom/microsoft/rest/ServiceResponseWithHeaders<TT;TTHeader;>;>;
    MethodParameters:
              Name  Flags
      observable    
      resourceType  
      headerType    final

  public <T, THeader> rx.Observable<com.microsoft.rest.ServiceResponseWithHeaders<T, THeader>> getPostOrDeleteResultWithHeadersAsync(rx.Observable<retrofit2.Response<okhttp3.ResponseBody>>, com.microsoft.azure.LongRunningOperationOptions, java.lang.reflect.Type, java.lang.Class<THeader>);
    descriptor: (Lrx/Observable;Lcom/microsoft/azure/LongRunningOperationOptions;Ljava/lang/reflect/Type;Ljava/lang/Class;)Lrx/Observable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=6, args_size=5
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // rx.Observable observable
        start local 2 // com.microsoft.azure.LongRunningOperationOptions lroOptions
        start local 3 // java.lang.reflect.Type resourceType
        start local 4 // java.lang.Class headerType
         0: .line 575
            aload 0 /* this */
            aload 1 /* observable */
            aload 2 /* lroOptions */
            aload 3 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.getPostOrDeleteResultAsync:(Lrx/Observable;Lcom/microsoft/azure/LongRunningOperationOptions;Ljava/lang/reflect/Type;)Lrx/Observable;
            astore 5 /* bodyResponse */
        start local 5 // rx.Observable bodyResponse
         1: .line 576
            aload 5 /* bodyResponse */
         2: .line 577
            new com.microsoft.azure.AzureClient$23
            dup
            aload 0 /* this */
            aload 4 /* headerType */
            invokespecial com.microsoft.azure.AzureClient$23.<init>:(Lcom/microsoft/azure/AzureClient;Ljava/lang/Class;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         3: .line 576
            areturn
        end local 5 // rx.Observable bodyResponse
        end local 4 // java.lang.Class headerType
        end local 3 // java.lang.reflect.Type resourceType
        end local 2 // com.microsoft.azure.LongRunningOperationOptions lroOptions
        end local 1 // rx.Observable observable
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    4     0          this  Lcom/microsoft/azure/AzureClient;
            0    4     1    observable  Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
            0    4     2    lroOptions  Lcom/microsoft/azure/LongRunningOperationOptions;
            0    4     3  resourceType  Ljava/lang/reflect/Type;
            0    4     4    headerType  Ljava/lang/Class<TTHeader;>;
            1    4     5  bodyResponse  Lrx/Observable<Lcom/microsoft/rest/ServiceResponse<TT;>;>;
    Signature: <T:Ljava/lang/Object;THeader:Ljava/lang/Object;>(Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;Lcom/microsoft/azure/LongRunningOperationOptions;Ljava/lang/reflect/Type;Ljava/lang/Class<TTHeader;>;)Lrx/Observable<Lcom/microsoft/rest/ServiceResponseWithHeaders<TT;TTHeader;>;>;
    MethodParameters:
              Name  Flags
      observable    
      lroOptions    final
      resourceType  
      headerType    final

  public <T> rx.Single<com.microsoft.azure.PollingState<T>> pollSingleAsync(com.microsoft.azure.PollingState<T>, java.lang.reflect.Type);
    descriptor: (Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)Lrx/Single;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 606
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.initialHttpMethod:()Ljava/lang/String;
            ldc "PUT"
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifne 2
         1: .line 607
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.initialHttpMethod:()Ljava/lang/String;
            ldc "PATCH"
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifeq 3
         2: .line 608
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* pollingState */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.pollPutOrPatchSingleAsync:(Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)Lrx/Single;
            areturn
         3: .line 610
      StackMap locals:
      StackMap stack:
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.initialHttpMethod:()Ljava/lang/String;
            ldc "POST"
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifne 5
         4: .line 611
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.initialHttpMethod:()Ljava/lang/String;
            ldc "DELETE"
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifeq 6
         5: .line 612
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* pollingState */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.pollPostOrDeleteSingleAsync:(Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)Lrx/Single;
            areturn
         6: .line 614
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "PollingState contains unsupported http method:"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.initialHttpMethod:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    7     0          this  Lcom/microsoft/azure/AzureClient;
            0    7     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
            0    7     2  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;Ljava/lang/reflect/Type;)Lrx/Single<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final
      resourceType  final

  public <T> rx.Observable<com.microsoft.azure.PollingState<T>> pollAsync(com.microsoft.azure.PollingState<T>, java.lang.reflect.Type);
    descriptor: (Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)Lrx/Observable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
        start local 2 // java.lang.reflect.Type resourceType
         0: .line 628
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.initialHttpMethod:()Ljava/lang/String;
            ldc "PUT"
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifne 2
         1: .line 629
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.initialHttpMethod:()Ljava/lang/String;
            ldc "PATCH"
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifeq 3
         2: .line 630
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* pollingState */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.pollPutOrPatchAsync:(Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)Lrx/Observable;
            areturn
         3: .line 632
      StackMap locals:
      StackMap stack:
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.initialHttpMethod:()Ljava/lang/String;
            ldc "POST"
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifne 5
         4: .line 633
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.initialHttpMethod:()Ljava/lang/String;
            ldc "DELETE"
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifeq 6
         5: .line 634
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* pollingState */
            aload 2 /* resourceType */
            invokevirtual com.microsoft.azure.AzureClient.pollPostOrDeleteAsync:(Lcom/microsoft/azure/PollingState;Ljava/lang/reflect/Type;)Lrx/Observable;
            areturn
         6: .line 636
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "PollingState contains unsupported http method:"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.initialHttpMethod:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
        end local 2 // java.lang.reflect.Type resourceType
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    7     0          this  Lcom/microsoft/azure/AzureClient;
            0    7     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
            0    7     2  resourceType  Ljava/lang/reflect/Type;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;Ljava/lang/reflect/Type;)Lrx/Observable<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final
      resourceType  final

  private <T> rx.Observable<com.microsoft.azure.PollingState<T>> updateStateFromLocationHeaderOnPutAsync(com.microsoft.azure.PollingState<T>);
    descriptor: (Lcom/microsoft/azure/PollingState;)Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
         0: .line 647
            aload 0 /* this */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.locationHeaderLink:()Ljava/lang/String;
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.loggingContext:()Ljava/lang/String;
            invokevirtual com.microsoft.azure.AzureClient.pollAsync:(Ljava/lang/String;Ljava/lang/String;)Lrx/Observable;
         1: .line 648
            new com.microsoft.azure.AzureClient$24
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$24.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         2: .line 647
            areturn
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lcom/microsoft/azure/AzureClient;
            0    3     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;)Lrx/Observable<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final

  private <T> rx.Observable<com.microsoft.azure.PollingState<T>> updateStateFromLocationHeaderOnPostOrDeleteAsync(com.microsoft.azure.PollingState<T>);
    descriptor: (Lcom/microsoft/azure/PollingState;)Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
         0: .line 675
            aload 0 /* this */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.locationHeaderLink:()Ljava/lang/String;
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.loggingContext:()Ljava/lang/String;
            invokevirtual com.microsoft.azure.AzureClient.pollAsync:(Ljava/lang/String;Ljava/lang/String;)Lrx/Observable;
         1: .line 676
            new com.microsoft.azure.AzureClient$25
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$25.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         2: .line 675
            areturn
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lcom/microsoft/azure/AzureClient;
            0    3     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;)Lrx/Observable<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final

  private <T> rx.Observable<com.microsoft.azure.PollingState<T>> updateStateFromGetResourceOperationAsync(com.microsoft.azure.PollingState<T>, java.lang.String);
    descriptor: (Lcom/microsoft/azure/PollingState;Ljava/lang/String;)Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
        start local 2 // java.lang.String url
         0: .line 704
            aload 0 /* this */
            aload 2 /* url */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.loggingContext:()Ljava/lang/String;
            invokevirtual com.microsoft.azure.AzureClient.pollAsync:(Ljava/lang/String;Ljava/lang/String;)Lrx/Observable;
         1: .line 705
            new com.microsoft.azure.AzureClient$26
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$26.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         2: .line 704
            areturn
        end local 2 // java.lang.String url
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lcom/microsoft/azure/AzureClient;
            0    3     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
            0    3     2           url  Ljava/lang/String;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;Ljava/lang/String;)Lrx/Observable<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final
      url           

  private <T> rx.Observable<com.microsoft.azure.PollingState<T>> updateStateFromAzureAsyncOperationHeaderOnPutAsync(com.microsoft.azure.PollingState<T>);
    descriptor: (Lcom/microsoft/azure/PollingState;)Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
         0: .line 726
            aload 0 /* this */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.azureAsyncOperationHeaderLink:()Ljava/lang/String;
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.loggingContext:()Ljava/lang/String;
            invokevirtual com.microsoft.azure.AzureClient.pollAsync:(Ljava/lang/String;Ljava/lang/String;)Lrx/Observable;
         1: .line 727
            new com.microsoft.azure.AzureClient$27
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$27.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         2: .line 726
            areturn
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lcom/microsoft/azure/AzureClient;
            0    3     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;)Lrx/Observable<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final

  private <T> rx.Observable<com.microsoft.azure.PollingState<T>> updateStateFromAzureAsyncOperationHeaderOnPostOrDeleteAsync(com.microsoft.azure.PollingState<T>);
    descriptor: (Lcom/microsoft/azure/PollingState;)Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
         0: .line 753
            aload 0 /* this */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.azureAsyncOperationHeaderLink:()Ljava/lang/String;
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.loggingContext:()Ljava/lang/String;
            invokevirtual com.microsoft.azure.AzureClient.pollAsync:(Ljava/lang/String;Ljava/lang/String;)Lrx/Observable;
         1: .line 754
            new com.microsoft.azure.AzureClient$28
            dup
            aload 0 /* this */
            aload 1 /* pollingState */
            invokespecial com.microsoft.azure.AzureClient$28.<init>:(Lcom/microsoft/azure/AzureClient;Lcom/microsoft/azure/PollingState;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         2: .line 753
            areturn
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lcom/microsoft/azure/AzureClient;
            0    3     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;)Lrx/Observable<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  final

  private rx.Observable<retrofit2.Response<okhttp3.ResponseBody>> pollAsync(java.lang.String, java.lang.String);
    descriptor: (Ljava/lang/String;Ljava/lang/String;)Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=5, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // java.lang.String url
        start local 2 // java.lang.String loggingContext
         0: .line 786
            new java.net.URL
            dup
            aload 1 /* url */
            invokespecial java.net.URL.<init>:(Ljava/lang/String;)V
            astore 3 /* endpoint */
        start local 3 // java.net.URL endpoint
         1: .line 787
            goto 4
        end local 3 // java.net.URL endpoint
      StackMap locals:
      StackMap stack: java.net.MalformedURLException
         2: astore 4 /* e */
        start local 4 // java.net.MalformedURLException e
         3: .line 788
            aload 4 /* e */
            invokestatic rx.Observable.error:(Ljava/lang/Throwable;)Lrx/Observable;
            areturn
        end local 4 // java.net.MalformedURLException e
        start local 3 // java.net.URL endpoint
         4: .line 790
      StackMap locals: java.net.URL
      StackMap stack:
            aload 0 /* this */
            invokevirtual com.microsoft.azure.AzureClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokevirtual com.microsoft.rest.RestClient.retrofit:()Lretrofit2/Retrofit;
            ldc Lcom/microsoft/azure/AzureClient$AsyncService;
            invokevirtual retrofit2.Retrofit.create:(Ljava/lang/Class;)Ljava/lang/Object;
            checkcast com.microsoft.azure.AzureClient$AsyncService
            astore 4 /* service */
        start local 4 // com.microsoft.azure.AzureClient$AsyncService service
         5: .line 791
            aload 2 /* loggingContext */
            ifnull 7
            aload 2 /* loggingContext */
            ldc " (poll)"
            invokevirtual java.lang.String.endsWith:(Ljava/lang/String;)Z
            ifne 7
         6: .line 792
            new java.lang.StringBuilder
            dup
            aload 2 /* loggingContext */
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc " (poll)"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            astore 2 /* loggingContext */
         7: .line 794
      StackMap locals: com.microsoft.azure.AzureClient$AsyncService
      StackMap stack:
            aload 4 /* service */
            aload 3 /* endpoint */
            invokevirtual java.net.URL.getFile:()Ljava/lang/String;
            aload 0 /* this */
            getfield com.microsoft.azure.AzureClient.serviceClientUserAgent:Ljava/lang/String;
            aload 2 /* loggingContext */
            invokeinterface com.microsoft.azure.AzureClient$AsyncService.get:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lrx/Observable;
         8: .line 795
            new com.microsoft.azure.AzureClient$29
            dup
            aload 0 /* this */
            invokespecial com.microsoft.azure.AzureClient$29.<init>:(Lcom/microsoft/azure/AzureClient;)V
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         9: .line 794
            areturn
        end local 4 // com.microsoft.azure.AzureClient$AsyncService service
        end local 3 // java.net.URL endpoint
        end local 2 // java.lang.String loggingContext
        end local 1 // java.lang.String url
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   10     0            this  Lcom/microsoft/azure/AzureClient;
            0   10     1             url  Ljava/lang/String;
            0   10     2  loggingContext  Ljava/lang/String;
            1    2     3        endpoint  Ljava/net/URL;
            4   10     3        endpoint  Ljava/net/URL;
            3    4     4               e  Ljava/net/MalformedURLException;
            5   10     4         service  Lcom/microsoft/azure/AzureClient$AsyncService;
      Exception table:
        from    to  target  type
           0     1       2  Class java.net.MalformedURLException
    Signature: (Ljava/lang/String;Ljava/lang/String;)Lrx/Observable<Lretrofit2/Response<Lokhttp3/ResponseBody;>;>;
    MethodParameters:
                Name  Flags
      url             
      loggingContext  

  private java.lang.RuntimeException createExceptionFromResponse(retrofit2.Response<okhttp3.ResponseBody>, java.lang.Integer[]);
    descriptor: (Lretrofit2/Response;[Ljava/lang/Integer;)Ljava/lang/RuntimeException;
    flags: (0x0082) ACC_PRIVATE, ACC_VARARGS
    Code:
      stack=5, locals=8, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // retrofit2.Response response
        start local 2 // java.lang.Integer[] allowedStatusCodes
         0: .line 809
            aload 1 /* response */
            invokevirtual retrofit2.Response.code:()I
            istore 3 /* statusCode */
        start local 3 // int statusCode
         1: .line 811
            aload 1 /* response */
            invokevirtual retrofit2.Response.isSuccessful:()Z
            ifeq 4
         2: .line 812
            aload 1 /* response */
            invokevirtual retrofit2.Response.body:()Ljava/lang/Object;
            checkcast okhttp3.ResponseBody
            astore 4 /* responseBody */
        start local 4 // okhttp3.ResponseBody responseBody
         3: .line 813
            goto 5
        end local 4 // okhttp3.ResponseBody responseBody
         4: .line 814
      StackMap locals: int
      StackMap stack:
            aload 1 /* response */
            invokevirtual retrofit2.Response.errorBody:()Lokhttp3/ResponseBody;
            astore 4 /* responseBody */
        start local 4 // okhttp3.ResponseBody responseBody
         5: .line 816
      StackMap locals: okhttp3.ResponseBody
      StackMap stack:
            aload 2 /* allowedStatusCodes */
            invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
            iload 3 /* statusCode */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
            ifne 16
         6: .line 819
            aload 4 /* responseBody */
            invokevirtual okhttp3.ResponseBody.string:()Ljava/lang/String;
            astore 6 /* bodyString */
        start local 6 // java.lang.String bodyString
         7: .line 820
            aload 0 /* this */
            invokevirtual com.microsoft.azure.AzureClient.restClient:()Lcom/microsoft/rest/RestClient;
            invokevirtual com.microsoft.rest.RestClient.serializerAdapter:()Lcom/microsoft/rest/protocol/SerializerAdapter;
            aload 6 /* bodyString */
            ldc Lcom/microsoft/azure/CloudError;
            invokeinterface com.microsoft.rest.protocol.SerializerAdapter.deserialize:(Ljava/lang/String;Ljava/lang/reflect/Type;)Ljava/lang/Object;
            checkcast com.microsoft.azure.CloudError
            astore 7 /* errorBody */
        start local 7 // com.microsoft.azure.CloudError errorBody
         8: .line 821
            aload 7 /* errorBody */
            ifnull 11
         9: .line 822
            new com.microsoft.azure.CloudException
            dup
            aload 7 /* errorBody */
            invokevirtual com.microsoft.azure.CloudError.message:()Ljava/lang/String;
            aload 1 /* response */
            aload 7 /* errorBody */
            invokespecial com.microsoft.azure.CloudException.<init>:(Ljava/lang/String;Lretrofit2/Response;Lcom/microsoft/azure/CloudError;)V
            astore 5 /* exception */
        start local 5 // com.microsoft.azure.CloudException exception
        10: .line 823
            goto 12
        end local 5 // com.microsoft.azure.CloudException exception
        11: .line 824
      StackMap locals: com.microsoft.azure.AzureClient retrofit2.Response java.lang.Integer[] int okhttp3.ResponseBody top java.lang.String com.microsoft.azure.CloudError
      StackMap stack:
            new com.microsoft.azure.CloudException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Unknown error with status code "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 3 /* statusCode */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " and body "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 6 /* bodyString */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 1 /* response */
            aconst_null
            invokespecial com.microsoft.azure.CloudException.<init>:(Ljava/lang/String;Lretrofit2/Response;Lcom/microsoft/azure/CloudError;)V
            astore 5 /* exception */
        start local 5 // com.microsoft.azure.CloudException exception
        12: .line 826
      StackMap locals: com.microsoft.azure.AzureClient retrofit2.Response java.lang.Integer[] int okhttp3.ResponseBody com.microsoft.azure.CloudException java.lang.String com.microsoft.azure.CloudError
      StackMap stack:
            aload 5 /* exception */
        13: areturn
        end local 7 // com.microsoft.azure.CloudError errorBody
        end local 6 // java.lang.String bodyString
        end local 5 // com.microsoft.azure.CloudException exception
        14: .line 827
      StackMap locals: com.microsoft.azure.AzureClient retrofit2.Response java.lang.Integer[] int okhttp3.ResponseBody
      StackMap stack: java.io.IOException
            astore 6 /* e */
        start local 6 // java.io.IOException e
        15: .line 829
            new java.lang.RuntimeException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Unknown error with status code "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 3 /* statusCode */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 6 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            areturn
        end local 6 // java.io.IOException e
        16: .line 832
      StackMap locals:
      StackMap stack:
            aconst_null
            areturn
        end local 4 // okhttp3.ResponseBody responseBody
        end local 3 // int statusCode
        end local 2 // java.lang.Integer[] allowedStatusCodes
        end local 1 // retrofit2.Response response
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   17     0                this  Lcom/microsoft/azure/AzureClient;
            0   17     1            response  Lretrofit2/Response<Lokhttp3/ResponseBody;>;
            0   17     2  allowedStatusCodes  [Ljava/lang/Integer;
            1   17     3          statusCode  I
            3    4     4        responseBody  Lokhttp3/ResponseBody;
            5   17     4        responseBody  Lokhttp3/ResponseBody;
           10   11     5           exception  Lcom/microsoft/azure/CloudException;
           12   14     5           exception  Lcom/microsoft/azure/CloudException;
            7   14     6          bodyString  Ljava/lang/String;
            8   14     7           errorBody  Lcom/microsoft/azure/CloudError;
           15   16     6                   e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           6    13      14  Class java.io.IOException
    Signature: (Lretrofit2/Response<Lokhttp3/ResponseBody;>;[Ljava/lang/Integer;)Ljava/lang/RuntimeException;
    MethodParameters:
                    Name  Flags
      response            
      allowedStatusCodes  

  private <T> rx.Observable<com.microsoft.azure.PollingState<T>> putOrPatchPollingDispatcher(com.microsoft.azure.PollingState<T>, java.lang.String);
    descriptor: (Lcom/microsoft/azure/PollingState;Ljava/lang/String;)Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
        start local 2 // java.lang.String url
         0: .line 836
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.azureAsyncOperationHeaderLink:()Ljava/lang/String;
            ifnull 2
         1: .line 837
            aload 0 /* this */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.AzureClient.updateStateFromAzureAsyncOperationHeaderOnPutAsync:(Lcom/microsoft/azure/PollingState;)Lrx/Observable;
            areturn
         2: .line 838
      StackMap locals:
      StackMap stack:
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.locationHeaderLink:()Ljava/lang/String;
            ifnull 4
         3: .line 839
            aload 0 /* this */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.AzureClient.updateStateFromLocationHeaderOnPutAsync:(Lcom/microsoft/azure/PollingState;)Lrx/Observable;
            areturn
         4: .line 841
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* pollingState */
            aload 2 /* url */
            invokevirtual com.microsoft.azure.AzureClient.updateStateFromGetResourceOperationAsync:(Lcom/microsoft/azure/PollingState;Ljava/lang/String;)Lrx/Observable;
            areturn
        end local 2 // java.lang.String url
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    5     0          this  Lcom/microsoft/azure/AzureClient;
            0    5     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
            0    5     2           url  Ljava/lang/String;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;Ljava/lang/String;)Lrx/Observable<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  
      url           

  private <T> rx.Observable<com.microsoft.azure.PollingState<T>> postOrDeletePollingDispatcher(com.microsoft.azure.PollingState<T>);
    descriptor: (Lcom/microsoft/azure/PollingState;)Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // com.microsoft.azure.AzureClient this
        start local 1 // com.microsoft.azure.PollingState pollingState
         0: .line 846
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.azureAsyncOperationHeaderLink:()Ljava/lang/String;
            ifnull 2
         1: .line 847
            aload 0 /* this */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.AzureClient.updateStateFromAzureAsyncOperationHeaderOnPostOrDeleteAsync:(Lcom/microsoft/azure/PollingState;)Lrx/Observable;
            areturn
         2: .line 848
      StackMap locals:
      StackMap stack:
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.locationHeaderLink:()Ljava/lang/String;
            ifnull 4
         3: .line 849
            aload 0 /* this */
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.AzureClient.updateStateFromLocationHeaderOnPostOrDeleteAsync:(Lcom/microsoft/azure/PollingState;)Lrx/Observable;
            areturn
         4: .line 851
      StackMap locals:
      StackMap stack:
            new com.microsoft.azure.CloudException
            dup
            ldc "Response does not contain an Azure-AsyncOperation or Location header."
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.response:()Lretrofit2/Response;
            aload 1 /* pollingState */
            invokevirtual com.microsoft.azure.PollingState.errorBody:()Lcom/microsoft/azure/CloudError;
            invokespecial com.microsoft.azure.CloudException.<init>:(Ljava/lang/String;Lretrofit2/Response;Lcom/microsoft/azure/CloudError;)V
            astore 2 /* exception */
        start local 2 // com.microsoft.azure.CloudException exception
         5: .line 852
            aload 2 /* exception */
            invokestatic rx.Observable.error:(Ljava/lang/Throwable;)Lrx/Observable;
            areturn
        end local 2 // com.microsoft.azure.CloudException exception
        end local 1 // com.microsoft.azure.PollingState pollingState
        end local 0 // com.microsoft.azure.AzureClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    6     0          this  Lcom/microsoft/azure/AzureClient;
            0    6     1  pollingState  Lcom/microsoft/azure/PollingState<TT;>;
            5    6     2     exception  Lcom/microsoft/azure/CloudException;
    Signature: <T:Ljava/lang/Object;>(Lcom/microsoft/azure/PollingState<TT;>;)Lrx/Observable<Lcom/microsoft/azure/PollingState<TT;>;>;
    MethodParameters:
              Name  Flags
      pollingState  
}
SourceFile: "AzureClient.java"
NestMembers:
  com.microsoft.azure.AzureClient$1  com.microsoft.azure.AzureClient$10  com.microsoft.azure.AzureClient$11  com.microsoft.azure.AzureClient$12  com.microsoft.azure.AzureClient$13  com.microsoft.azure.AzureClient$14  com.microsoft.azure.AzureClient$15  com.microsoft.azure.AzureClient$16  com.microsoft.azure.AzureClient$17  com.microsoft.azure.AzureClient$18  com.microsoft.azure.AzureClient$19  com.microsoft.azure.AzureClient$19$1  com.microsoft.azure.AzureClient$2  com.microsoft.azure.AzureClient$20  com.microsoft.azure.AzureClient$20$1  com.microsoft.azure.AzureClient$21  com.microsoft.azure.AzureClient$22  com.microsoft.azure.AzureClient$23  com.microsoft.azure.AzureClient$24  com.microsoft.azure.AzureClient$25  com.microsoft.azure.AzureClient$26  com.microsoft.azure.AzureClient$27  com.microsoft.azure.AzureClient$28  com.microsoft.azure.AzureClient$29  com.microsoft.azure.AzureClient$3  com.microsoft.azure.AzureClient$4  com.microsoft.azure.AzureClient$5  com.microsoft.azure.AzureClient$6  com.microsoft.azure.AzureClient$7  com.microsoft.azure.AzureClient$8  com.microsoft.azure.AzureClient$8$1  com.microsoft.azure.AzureClient$9  com.microsoft.azure.AzureClient$9$1  com.microsoft.azure.AzureClient$AsyncService
InnerClasses:
  com.microsoft.azure.AzureClient$1
  com.microsoft.azure.AzureClient$10
  com.microsoft.azure.AzureClient$11
  com.microsoft.azure.AzureClient$12
  com.microsoft.azure.AzureClient$13
  com.microsoft.azure.AzureClient$14
  com.microsoft.azure.AzureClient$15
  com.microsoft.azure.AzureClient$16
  com.microsoft.azure.AzureClient$17
  com.microsoft.azure.AzureClient$18
  com.microsoft.azure.AzureClient$19
  com.microsoft.azure.AzureClient$2
  com.microsoft.azure.AzureClient$20
  com.microsoft.azure.AzureClient$21
  com.microsoft.azure.AzureClient$22
  com.microsoft.azure.AzureClient$23
  com.microsoft.azure.AzureClient$24
  com.microsoft.azure.AzureClient$25
  com.microsoft.azure.AzureClient$26
  com.microsoft.azure.AzureClient$27
  com.microsoft.azure.AzureClient$28
  com.microsoft.azure.AzureClient$29
  com.microsoft.azure.AzureClient$3
  com.microsoft.azure.AzureClient$4
  com.microsoft.azure.AzureClient$5
  com.microsoft.azure.AzureClient$6
  com.microsoft.azure.AzureClient$7
  com.microsoft.azure.AzureClient$8
  com.microsoft.azure.AzureClient$9
  private abstract AsyncService = com.microsoft.azure.AzureClient$AsyncService of com.microsoft.azure.AzureClient