ek.smali

.class final Lio/reactivex/internal/operators/observable/ek;
.super Ljava/lang/Object;
.source "ObservableRefCount.java"

# interfaces
.implements Lio/reactivex/b/g;


# annotations
.annotation system Ldalvik/annotation/Signature;
    value = {
        "Ljava/lang/Object;",
        "Lio/reactivex/b/g",
        "<",
        "Lio/reactivex/disposables/b;",
        ">;"
    }
.end annotation


# instance fields
.field private final bQR:Ljava/util/concurrent/atomic/AtomicBoolean;

.field private final observer:Lio/reactivex/r;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Lio/reactivex/r",
            "<-TT;>;"
        }
    .end annotation
.end field

.field private synthetic this$0:Lio/reactivex/internal/operators/observable/ObservableRefCount;


# direct methods
.method constructor <init>(Lio/reactivex/internal/operators/observable/ObservableRefCount;Lio/reactivex/r;Ljava/util/concurrent/atomic/AtomicBoolean;)V
    .registers 4
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/r",
            "<-TT;>;",
            "Ljava/util/concurrent/atomic/AtomicBoolean;",
            ")V"
        }
    .end annotation

    .prologue
    .line 183
    iput-object p1, p0, Lio/reactivex/internal/operators/observable/ek;->this$0:Lio/reactivex/internal/operators/observable/ObservableRefCount;

    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    .line 184
    iput-object p2, p0, Lio/reactivex/internal/operators/observable/ek;->observer:Lio/reactivex/r;

    .line 185
    iput-object p3, p0, Lio/reactivex/internal/operators/observable/ek;->bQR:Ljava/util/concurrent/atomic/AtomicBoolean;

    .line 186
    return-void
.end method


# virtual methods
.method public final synthetic accept(Ljava/lang/Object;)V
    .registers 6

    .prologue
    const/4 v3, 0x0

    .line 179
    check-cast p1, Lio/reactivex/disposables/b;

    .line 1191
    :try_start_3
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/ek;->this$0:Lio/reactivex/internal/operators/observable/ObservableRefCount;

    iget-object v0, v0, Lio/reactivex/internal/operators/observable/ObservableRefCount;->bQP:Lio/reactivex/disposables/a;

    invoke-virtual {v0, p1}, Lio/reactivex/disposables/a;->a(Lio/reactivex/disposables/b;)Z

    .line 1193
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/ek;->this$0:Lio/reactivex/internal/operators/observable/ObservableRefCount;

    iget-object v1, p0, Lio/reactivex/internal/operators/observable/ek;->observer:Lio/reactivex/r;

    iget-object v2, p0, Lio/reactivex/internal/operators/observable/ek;->this$0:Lio/reactivex/internal/operators/observable/ObservableRefCount;

    iget-object v2, v2, Lio/reactivex/internal/operators/observable/ObservableRefCount;->bQP:Lio/reactivex/disposables/a;

    invoke-virtual {v0, v1, v2}, Lio/reactivex/internal/operators/observable/ObservableRefCount;->a(Lio/reactivex/r;Lio/reactivex/disposables/a;)V
    :try_end_15
    .catchall {:try_start_3 .. :try_end_15} :catchall_22

    .line 1196
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/ek;->this$0:Lio/reactivex/internal/operators/observable/ObservableRefCount;

    iget-object v0, v0, Lio/reactivex/internal/operators/observable/ObservableRefCount;->lock:Ljava/util/concurrent/locks/ReentrantLock;

    invoke-virtual {v0}, Ljava/util/concurrent/locks/ReentrantLock;->unlock()V

    .line 1197
    iget-object v0, p0, Lio/reactivex/internal/operators/observable/ek;->bQR:Ljava/util/concurrent/atomic/AtomicBoolean;

    invoke-virtual {v0, v3}, Ljava/util/concurrent/atomic/AtomicBoolean;->set(Z)V

    .line 1198
    return-void

    .line 1196
    :catchall_22
    move-exception v0

    iget-object v1, p0, Lio/reactivex/internal/operators/observable/ek;->this$0:Lio/reactivex/internal/operators/observable/ObservableRefCount;

    iget-object v1, v1, Lio/reactivex/internal/operators/observable/ObservableRefCount;->lock:Ljava/util/concurrent/locks/ReentrantLock;

    invoke-virtual {v1}, Ljava/util/concurrent/locks/ReentrantLock;->unlock()V

    .line 1197
    iget-object v1, p0, Lio/reactivex/internal/operators/observable/ek;->bQR:Ljava/util/concurrent/atomic/AtomicBoolean;

    invoke-virtual {v1, v3}, Ljava/util/concurrent/atomic/AtomicBoolean;->set(Z)V

    throw v0
.end method