public class com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup extends com.microsoft.azure.management.resources.fluentcore.dag.DAGraph<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem, com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem>> implements com.microsoft.azure.management.resources.fluentcore.model.Indexable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup
super_class: com.microsoft.azure.management.resources.fluentcore.dag.DAGraph
{
private final com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem> rootTaskEntry;
descriptor: Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
private com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupTerminateOnErrorStrategy taskGroupTerminateOnErrorStrategy;
descriptor: Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupTerminateOnErrorStrategy;
flags: (0x0002) ACC_PRIVATE
private java.util.concurrent.atomic.AtomicBoolean isGroupCancelled;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0002) ACC_PRIVATE
private final com.microsoft.azure.management.resources.fluentcore.dag.TaskCancelledException taskCancelledException;
descriptor: Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskCancelledException;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
protected com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskGroupWrapper proxyTaskGroupWrapper;
descriptor: Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$ProxyTaskGroupWrapper;
flags: (0x0004) ACC_PROTECTED
private void <init>(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem>);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.DAGraph.<init>:(Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;)V
1: aload 0
new com.microsoft.azure.management.resources.fluentcore.dag.TaskCancelledException
dup
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.TaskCancelledException.<init>:()V
putfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.taskCancelledException:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskCancelledException;
2: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
putfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.isGroupCancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
3: aload 0
aload 1
putfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.rootTaskEntry:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;
4: aload 0
new com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskGroupWrapper
dup
aload 0
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskGroupWrapper.<init>:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;)V
putfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.proxyTaskGroupWrapper:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$ProxyTaskGroupWrapper;
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 6 1 rootTaskEntry Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
Signature: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;)V
MethodParameters:
Name Flags
rootTaskEntry
public void <init>(java.lang.String, com.microsoft.azure.management.resources.fluentcore.dag.TaskItem);
descriptor: (Ljava/lang/String;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
new com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
dup
aload 1
aload 2
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry.<init>:(Ljava/lang/String;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;)V
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.<init>:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 2 1 rootTaskItemId Ljava/lang/String;
0 2 2 rootTaskItem Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;
MethodParameters:
Name Flags
rootTaskItemId
rootTaskItem
public void <init>(com.microsoft.azure.management.resources.fluentcore.dag.IndexableTaskItem);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/IndexableTaskItem;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
dup
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.IndexableTaskItem.key:()Ljava/lang/String;
aload 1
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry.<init>:(Ljava/lang/String;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;)V
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.<init>:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 2 1 rootTaskItem Lcom/microsoft/azure/management/resources/fluentcore/dag/IndexableTaskItem;
MethodParameters:
Name Flags
rootTaskItem
public java.lang.String key();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.rootTaskEntry:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry.key:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
public com.microsoft.azure.management.resources.fluentcore.model.Indexable taskResult(java.lang.String);
descriptor: (Ljava/lang/String;)Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.DAGraph.getNode:(Ljava/lang/String;)Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;
checkcast com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
astore 2
start local 2 1: aload 2
ifnull 3
2: aload 2
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry.taskResult:()Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;
areturn
3: StackMap locals: com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
StackMap stack:
aload 0
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.proxyTaskGroupWrapper:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$ProxyTaskGroupWrapper;
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskGroupWrapper.isActive:()Z
ifne 5
4: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "A dependency task with id '"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "' is not found"
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
5: StackMap locals:
StackMap stack:
aload 0
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.proxyTaskGroupWrapper:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$ProxyTaskGroupWrapper;
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskGroupWrapper.proxyTaskGroup:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.getNode:(Ljava/lang/String;)Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;
checkcast com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
astore 2
6: aload 2
ifnull 8
7: aload 2
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry.taskResult:()Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;
areturn
8: StackMap locals:
StackMap stack:
new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "A dependency task or 'post-run' dependent task with with id '"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "' not found"
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 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 9 1 taskId Ljava/lang/String;
1 9 2 taskGroupEntry Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
MethodParameters:
Name Flags
taskId
public boolean dependsOn(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.nodeTable:Ljava/util/Map;
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.root:()Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry.key:()Ljava/lang/String;
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 1 1 taskGroup Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
MethodParameters:
Name Flags
taskGroup
protected com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem> root();
descriptor: ()Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.rootTaskEntry:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
Signature: ()Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
public java.lang.String addDependency(com.microsoft.azure.management.resources.fluentcore.dag.FunctionalTaskItem);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/FunctionalTaskItem;)Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokestatic com.microsoft.azure.management.resources.fluentcore.dag.IndexableTaskItem.create:(Lcom/microsoft/azure/management/resources/fluentcore/dag/FunctionalTaskItem;)Lcom/microsoft/azure/management/resources/fluentcore/dag/IndexableTaskItem;
astore 2
start local 2 1: aload 0
aload 2
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.addDependency:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$HasTaskGroup;)V
2: aload 2
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.IndexableTaskItem.key:()Ljava/lang/String;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 3 1 dependencyTaskItem Lcom/microsoft/azure/management/resources/fluentcore/dag/FunctionalTaskItem;
1 3 2 dependency Lcom/microsoft/azure/management/resources/fluentcore/dag/IndexableTaskItem;
MethodParameters:
Name Flags
dependencyTaskItem
public void addDependency(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$HasTaskGroup);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$HasTaskGroup;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$HasTaskGroup.taskGroup:()Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.addDependencyTaskGroup:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 2 1 hasTaskGroup Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$HasTaskGroup;
MethodParameters:
Name Flags
hasTaskGroup
public void addDependencyTaskGroup(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.proxyTaskGroupWrapper:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$ProxyTaskGroupWrapper;
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskGroupWrapper.isActive:()Z
ifeq 3
1: aload 1
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.proxyTaskGroupWrapper:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$ProxyTaskGroupWrapper;
aload 0
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskGroupWrapper.addDependentTaskGroup:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;)V
2: goto 5
3: StackMap locals:
StackMap stack:
aload 1
astore 2
start local 2 4: aload 0
aload 2
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.DAGraph.addDependencyGraph:(Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGraph;)V
end local 2 5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 6 1 dependencyTaskGroup Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
4 5 2 dependencyGraph Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGraph<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;>;
MethodParameters:
Name Flags
dependencyTaskGroup
public java.lang.String addPostRunDependent(com.microsoft.azure.management.resources.fluentcore.dag.FunctionalTaskItem);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/FunctionalTaskItem;)Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokestatic com.microsoft.azure.management.resources.fluentcore.dag.IndexableTaskItem.create:(Lcom/microsoft/azure/management/resources/fluentcore/dag/FunctionalTaskItem;)Lcom/microsoft/azure/management/resources/fluentcore/dag/IndexableTaskItem;
astore 2
start local 2 1: aload 0
aload 2
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.addPostRunDependent:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$HasTaskGroup;)V
2: aload 2
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.IndexableTaskItem.key:()Ljava/lang/String;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 3 1 dependentTaskItem Lcom/microsoft/azure/management/resources/fluentcore/dag/FunctionalTaskItem;
1 3 2 taskItem Lcom/microsoft/azure/management/resources/fluentcore/dag/IndexableTaskItem;
MethodParameters:
Name Flags
dependentTaskItem
public void addPostRunDependent(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$HasTaskGroup);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$HasTaskGroup;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$HasTaskGroup.taskGroup:()Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.addPostRunDependentTaskGroup:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 2 1 hasTaskGroup Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$HasTaskGroup;
MethodParameters:
Name Flags
hasTaskGroup
public void addPostRunDependentTaskGroup(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.proxyTaskGroupWrapper:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$ProxyTaskGroupWrapper;
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskGroupWrapper.addPostRunTaskGroupForActualTaskGroup:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 2 1 dependentTaskGroup Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
MethodParameters:
Name Flags
dependentTaskGroup
public rx.Observable<com.microsoft.azure.management.resources.fluentcore.model.Indexable> invokeAsync(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$1
dup
aload 0
aload 1
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$1.<init>:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)V
invokestatic rx.Observable.defer:(Lrx/functions/Func0;)Lrx/Observable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 1 1 context Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;
Signature: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable<Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;>;
MethodParameters:
Name Flags
context final
private rx.Observable<com.microsoft.azure.management.resources.fluentcore.model.Indexable> invokeInternAsync(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext, boolean, java.util.Set<java.lang.String>);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;ZLjava/util/Set;)Lrx/Observable;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.isPreparer:()Z
ifne 2
1: new java.lang.IllegalStateException
dup
ldc "invokeInternAsync(cxt) can be called only from root TaskGroup"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
invokestatic rx.Observable.error:(Ljava/lang/Throwable;)Lrx/Observable;
areturn
2: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext.terminateOnErrorStrategy:()Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupTerminateOnErrorStrategy;
putfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.taskGroupTerminateOnErrorStrategy:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupTerminateOnErrorStrategy;
3: iload 2
ifeq 5
4: aload 0
aload 3
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.runBeforeGroupInvoke:(Ljava/util/Set;)Ljava/util/Set;
pop
5: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.invokeReadyTasksAsync:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 6 1 context Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;
0 6 2 shouldRunBeforeGroupInvoke Z
0 6 3 skipBeforeGroupInvoke Ljava/util/Set<Ljava/lang/String;>;
Signature: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;ZLjava/util/Set<Ljava/lang/String;>;)Lrx/Observable<Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;>;
MethodParameters:
Name Flags
context final
shouldRunBeforeGroupInvoke final
skipBeforeGroupInvoke final
private java.util.Set<java.lang.String> runBeforeGroupInvoke(java.util.Set<java.lang.String>);
descriptor: (Ljava/util/Set;)Ljava/util/Set;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=7, args_size=2
start local 0 start local 1 0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 2
start local 2 1: aload 1
ifnull 3
2: aload 2
aload 1
invokevirtual java.util.HashSet.addAll:(Ljava/util/Collection;)Z
pop
3: StackMap locals: java.util.HashSet
StackMap stack:
aload 0
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.entriesSnapshot:()Ljava/util/List;
astore 3
start local 3 4: StackMap locals: java.util.List
StackMap stack:
iconst_0
istore 4
start local 4 5: aload 3
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 6
goto 10
StackMap locals: com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup java.util.Set java.util.HashSet java.util.List int top java.util.Iterator
StackMap stack:
6: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
astore 5
start local 5 7: aload 2
aload 5
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry.key:()Ljava/lang/String;
invokevirtual java.util.HashSet.contains:(Ljava/lang/Object;)Z
ifne 10
8: aload 5
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry.data:()Ljava/lang/Object;
checkcast com.microsoft.azure.management.resources.fluentcore.dag.TaskItem
invokeinterface com.microsoft.azure.management.resources.fluentcore.dag.TaskItem.beforeGroupInvoke:()V
9: aload 2
aload 5
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry.key:()Ljava/lang/String;
invokevirtual java.util.HashSet.add:(Ljava/lang/Object;)Z
pop
end local 5 10: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
11: aload 3
invokeinterface java.util.List.size:()I
istore 5
start local 5 12: aload 0
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.entriesSnapshot:()Ljava/util/List;
astore 3
13: aload 3
invokeinterface java.util.List.size:()I
iload 5
if_icmple 15
14: iconst_1
istore 4
end local 5 15: StackMap locals: com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup java.util.Set java.util.HashSet java.util.List int
StackMap stack:
iload 4
ifne 4
16: aload 0
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.DAGraph.prepareForEnumeration:()V
17: aload 2
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 18 1 skip Ljava/util/Set<Ljava/lang/String;>;
1 18 2 processedEntryKeys Ljava/util/HashSet<Ljava/lang/String;>;
4 18 3 entries Ljava/util/List<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;>;
5 18 4 hasMoreToProcess Z
7 10 5 entry Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
12 15 5 prevSize I
Signature: (Ljava/util/Set<Ljava/lang/String;>;)Ljava/util/Set<Ljava/lang/String;>;
MethodParameters:
Name Flags
skip final
private java.util.List<com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem>> entriesSnapshot();
descriptor: ()Ljava/util/List;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=1
start local 0 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 1
start local 1 1: aload 0
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.DAGraph.prepareForEnumeration:()V
2: aload 0
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.DAGraph.getNext:()Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;
checkcast com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
astore 2
start local 2 3: goto 7
4: StackMap locals: java.util.List com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
StackMap stack:
aload 1
aload 2
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
5: aload 0
aload 2
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.DAGraph.reportCompletion:(Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;)V
6: aload 0
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.DAGraph.getNext:()Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;
checkcast com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
astore 2
StackMap locals:
StackMap stack:
7: aload 2
ifnonnull 4
end local 2 8: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
1 9 1 entries Ljava/util/List<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;>;
3 8 2 current Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
Signature: ()Ljava/util/List<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;>;
private rx.Observable<com.microsoft.azure.management.resources.fluentcore.model.Indexable> invokeReadyTasksAsync(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=6, args_size=2
start local 0 start local 1 0: aload 0
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.DAGraph.getNext:()Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;
checkcast com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
astore 2
start local 2 1: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 3
start local 3 2: goto 10
3: StackMap locals: com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry java.util.List
StackMap stack:
aload 2
astore 4
start local 4 4: aload 4
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry.data:()Ljava/lang/Object;
checkcast com.microsoft.azure.management.resources.fluentcore.dag.TaskItem
astore 5
start local 5 5: aload 5
instanceof com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskItem
ifeq 8
6: aload 3
aload 0
aload 4
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.invokeAfterPostRunAsync:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
7: goto 9
8: StackMap locals: com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry com.microsoft.azure.management.resources.fluentcore.dag.TaskItem
StackMap stack:
aload 3
aload 0
aload 4
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.invokeTaskAsync:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
9: StackMap locals:
StackMap stack:
aload 0
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.DAGraph.getNext:()Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;
checkcast com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry
astore 2
end local 5 end local 4 10: StackMap locals:
StackMap stack:
aload 2
ifnonnull 3
11: aload 3
invokestatic rx.Observable.mergeDelayError:(Ljava/lang/Iterable;)Lrx/Observable;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 12 1 context Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;
1 12 2 readyTaskEntry Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
2 12 3 observables Ljava/util/List<Lrx/Observable<Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;>;>;
4 10 4 currentEntry Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
5 10 5 currentTaskItem Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;
Signature: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable<Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;>;
MethodParameters:
Name Flags
context final
private rx.Observable<com.microsoft.azure.management.resources.fluentcore.model.Indexable> invokeTaskAsync(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem>, com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$2
dup
aload 0
aload 1
aload 2
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$2.<init>:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)V
invokestatic rx.Observable.defer:(Lrx/functions/Func0;)Lrx/Observable;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 1 1 entry Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
0 1 2 context Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;
Signature: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable<Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;>;
MethodParameters:
Name Flags
entry final
context final
private rx.Observable<com.microsoft.azure.management.resources.fluentcore.model.Indexable> invokeAfterPostRunAsync(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem>, com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$3
dup
aload 0
aload 1
aload 2
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$3.<init>:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)V
invokestatic rx.Observable.defer:(Lrx/functions/Func0;)Lrx/Observable;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 1 1 entry Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
0 1 2 context Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;
Signature: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable<Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;>;
MethodParameters:
Name Flags
entry final
context final
private rx.Observable<com.microsoft.azure.management.resources.fluentcore.model.Indexable> processCompletedTaskAsync(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem>, com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.reportCompletion:(Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;)V
1: aload 0
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.isRootEntry:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;)Z
ifeq 3
2: invokestatic rx.Observable.empty:()Lrx/Observable;
areturn
3: StackMap locals:
StackMap stack:
aload 0
aload 2
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.invokeReadyTasksAsync:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 4 1 completedEntry Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
0 4 2 context Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;
Signature: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable<Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;>;
MethodParameters:
Name Flags
completedEntry final
context final
private rx.Observable<com.microsoft.azure.management.resources.fluentcore.model.Indexable> processFaultedTaskAsync(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem>, java.lang.Throwable, com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;Ljava/lang/Throwable;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.markGroupAsCancelledIfTerminationStrategyIsIPTC:()V
1: aload 0
aload 1
aload 2
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.reportError:(Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;Ljava/lang/Throwable;)V
2: aload 0
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.isRootEntry:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;)Z
ifeq 6
3: aload 2
invokestatic com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.shouldPropagateException:(Ljava/lang/Throwable;)Z
ifeq 5
4: aload 0
aload 2
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.toErrorObservable:(Ljava/lang/Throwable;)Lrx/Observable;
areturn
5: StackMap locals:
StackMap stack:
invokestatic rx.Observable.empty:()Lrx/Observable;
areturn
6: StackMap locals:
StackMap stack:
aload 2
invokestatic com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.shouldPropagateException:(Ljava/lang/Throwable;)Z
ifeq 8
7: aload 0
aload 3
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.invokeReadyTasksAsync:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
aload 0
aload 2
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.toErrorObservable:(Ljava/lang/Throwable;)Lrx/Observable;
invokestatic rx.Observable.concatDelayError:(Lrx/Observable;Lrx/Observable;)Lrx/Observable;
areturn
8: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.invokeReadyTasksAsync:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 9 1 faultedEntry Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
0 9 2 throwable Ljava/lang/Throwable;
0 9 3 context Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;
Signature: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;Ljava/lang/Throwable;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;)Lrx/Observable<Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;>;
MethodParameters:
Name Flags
faultedEntry final
throwable final
context final
private void markGroupAsCancelledIfTerminationStrategyIsIPTC();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.isGroupCancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
aload 0
getfield com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.taskGroupTerminateOnErrorStrategy:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupTerminateOnErrorStrategy;
getstatic com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupTerminateOnErrorStrategy.TERMINATE_ON_IN_PROGRESS_TASKS_COMPLETION:Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupTerminateOnErrorStrategy;
if_acmpne 1
iconst_1
goto 2
StackMap locals:
StackMap stack: java.util.concurrent.atomic.AtomicBoolean
1: iconst_0
StackMap locals: com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup
StackMap stack: java.util.concurrent.atomic.AtomicBoolean int
2: invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
private boolean isRootEntry(com.microsoft.azure.management.resources.fluentcore.dag.TaskGroupEntry<com.microsoft.azure.management.resources.fluentcore.dag.TaskItem>);
descriptor: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.isRootNode:(Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 1 1 taskGroupEntry Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;
Signature: (Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;)Z
MethodParameters:
Name Flags
taskGroupEntry
private static boolean shouldPropagateException(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
instanceof com.microsoft.azure.management.resources.fluentcore.dag.ErroredDependencyTaskException
ifne 3
1: aload 0
instanceof com.microsoft.azure.management.resources.fluentcore.dag.TaskCancelledException
ifne 3
2: iconst_1
ireturn
StackMap locals:
StackMap stack:
3: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 throwable Ljava/lang/Throwable;
MethodParameters:
Name Flags
throwable
private rx.Observable<com.microsoft.azure.management.resources.fluentcore.model.Indexable> toErrorObservable(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Lrx/Observable;
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokestatic rx.Observable.error:(Ljava/lang/Throwable;)Lrx/Observable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
0 1 1 throwable Ljava/lang/Throwable;
Signature: (Ljava/lang/Throwable;)Lrx/Observable<Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;>;
MethodParameters:
Name Flags
throwable
public com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext newInvocationContext();
descriptor: ()Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup$InvocationContext;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext
dup
aload 0
invokespecial com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext.<init>:(Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroup;
protected com.microsoft.azure.management.resources.fluentcore.dag.DAGNode root();
descriptor: ()Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGNode;
flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup.root:()Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: Lcom/microsoft/azure/management/resources/fluentcore/dag/DAGraph<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskGroupEntry<Lcom/microsoft/azure/management/resources/fluentcore/dag/TaskItem;>;>;Lcom/microsoft/azure/management/resources/fluentcore/model/Indexable;
SourceFile: "TaskGroup.java"
NestMembers:
com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$1 com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$2 com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$2$1 com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$2$2 com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$2$3 com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$3 com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$3$1 com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$3$2 com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$HasTaskGroup com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskGroupWrapper com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskItem com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskItem$1
InnerClasses:
com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$1
com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$2
com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$3
public abstract HasTaskGroup = com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$HasTaskGroup of com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup
public final InvocationContext = com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$InvocationContext of com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup
final ProxyTaskGroupWrapper = com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskGroupWrapper of com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup
private final ProxyTaskItem = com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup$ProxyTaskItem of com.microsoft.azure.management.resources.fluentcore.dag.TaskGroup