OperatorMerge.java 文件源码

rx.subscriptions.CompositeSubscription getOrCreateComposite() {
    /*
    r4 = this;
    r0 = r4.subscriptions;
    if (r0 != 0) goto L_0x0019;
L_0x0004:
    r2 = 0;
    monitor-enter(r4);
    r0 = r4.subscriptions;   Catch:{ all -> 0x001a }
    if (r0 != 0) goto L_0x0013;
L_0x000a:
    r1 = new rx.subscriptions.CompositeSubscription;     Catch:{ all -> 0x001a }
    r1.<init>();     Catch:{ all -> 0x001a }
    r4.subscriptions = r1;   Catch:{ all -> 0x001d }
    r2 = 1;
    r0 = r1;
L_0x0013:
    monitor-exit(r4);    Catch:{ all -> 0x001a }
    if (r2 == 0) goto L_0x0019;
L_0x0016:
    r4.add(r0);
L_0x0019:
    return r0;
L_0x001a:
    r3 = move-exception;
L_0x001b:
    monitor-exit(r4);    Catch:{ all -> 0x001a }
    throw r3;
L_0x001d:
    r3 = move-exception;
    r0 = r1;
    goto L_0x001b;
    */
    throw new UnsupportedOperationException("Method not decompiled: rx.internal.operators.OperatorMerge.MergeSubscriber.getOrCreateComposite():rx.subscriptions.CompositeSubscription");
}