.class public final enum Lio/reactivex/internal/disposables/DisposableHelper; .super Ljava/lang/Enum; .source "DisposableHelper.java" # interfaces .implements Lio/reactivex/disposables/Disposable; # annotations .annotation system Ldalvik/annotation/Signature; value = { "Ljava/lang/Enum<", "Lio/reactivex/internal/disposables/DisposableHelper;", ">;", "Lio/reactivex/disposables/Disposable;" } .end annotation # static fields .field private static final synthetic $VALUES:[Lio/reactivex/internal/disposables/DisposableHelper; .field public static final enum DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper; # direct methods .method static constructor ()V .locals 3 .line 29 new-instance v0, Lio/reactivex/internal/disposables/DisposableHelper; const/4 v1, 0x0 const-string v2, "DISPOSED" invoke-direct {v0, v2, v1}, Lio/reactivex/internal/disposables/DisposableHelper;->(Ljava/lang/String;I)V sput-object v0, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper; const/4 v0, 0x1 .line 25 new-array v0, v0, [Lio/reactivex/internal/disposables/DisposableHelper; sget-object v2, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper; aput-object v2, v0, v1 sput-object v0, Lio/reactivex/internal/disposables/DisposableHelper;->$VALUES:[Lio/reactivex/internal/disposables/DisposableHelper; return-void .end method .method private constructor (Ljava/lang/String;I)V .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "()V" } .end annotation .line 25 invoke-direct {p0, p1, p2}, Ljava/lang/Enum;->(Ljava/lang/String;I)V return-void .end method .method public static dispose(Ljava/util/concurrent/atomic/AtomicReference;)Z .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/atomic/AtomicReference<", "Lio/reactivex/disposables/Disposable;", ">;)Z" } .end annotation .line 117 invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v0 check-cast v0, Lio/reactivex/disposables/Disposable; .line 118 sget-object v1, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper; if-eq v0, v1, :cond_1 .line 120 invoke-virtual {p0, v1}, Ljava/util/concurrent/atomic/AtomicReference;->getAndSet(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p0 check-cast p0, Lio/reactivex/disposables/Disposable; if-eq p0, v1, :cond_1 if-eqz p0, :cond_0 .line 123 invoke-interface {p0}, Lio/reactivex/disposables/Disposable;->dispose()V :cond_0 const/4 p0, 0x1 return p0 :cond_1 const/4 p0, 0x0 return p0 .end method .method public static isDisposed(Lio/reactivex/disposables/Disposable;)Z .locals 1 .line 38 sget-object v0, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper; if-ne p0, v0, :cond_0 const/4 p0, 0x1 goto :goto_0 :cond_0 const/4 p0, 0x0 :goto_0 return p0 .end method .method public static replace(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/Disposable;)Z .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/atomic/AtomicReference<", "Lio/reactivex/disposables/Disposable;", ">;", "Lio/reactivex/disposables/Disposable;", ")Z" } .end annotation .line 98 :cond_0 invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v0 check-cast v0, Lio/reactivex/disposables/Disposable; .line 99 sget-object v1, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper; if-ne v0, v1, :cond_2 if-eqz p1, :cond_1 .line 101 invoke-interface {p1}, Lio/reactivex/disposables/Disposable;->dispose()V :cond_1 const/4 p0, 0x0 return p0 .line 105 :cond_2 invoke-virtual {p0, v0, p1}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z move-result v0 if-eqz v0, :cond_0 const/4 p0, 0x1 return p0 .end method .method public static reportDisposableSet()V .locals 2 .line 155 new-instance v0, Ljava/lang/IllegalStateException; const-string v1, "Disposable already set!" invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V invoke-static {v0}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V return-void .end method .method public static set(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/Disposable;)Z .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/atomic/AtomicReference<", "Lio/reactivex/disposables/Disposable;", ">;", "Lio/reactivex/disposables/Disposable;", ")Z" } .end annotation .line 49 :cond_0 invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object v0 check-cast v0, Lio/reactivex/disposables/Disposable; .line 50 sget-object v1, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper; if-ne v0, v1, :cond_2 if-eqz p1, :cond_1 .line 52 invoke-interface {p1}, Lio/reactivex/disposables/Disposable;->dispose()V :cond_1 const/4 p0, 0x0 return p0 .line 56 :cond_2 invoke-virtual {p0, v0, p1}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z move-result v1 if-eqz v1, :cond_0 if-eqz v0, :cond_3 .line 58 invoke-interface {v0}, Lio/reactivex/disposables/Disposable;->dispose()V :cond_3 const/4 p0, 0x1 return p0 .end method .method public static setOnce(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/Disposable;)Z .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/atomic/AtomicReference<", "Lio/reactivex/disposables/Disposable;", ">;", "Lio/reactivex/disposables/Disposable;", ")Z" } .end annotation const-string v0, "d is null" .line 77 invoke-static {p1, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; const/4 v0, 0x0 .line 78 invoke-virtual {p0, v0, p1}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z move-result v0 if-nez v0, :cond_1 .line 79 invoke-interface {p1}, Lio/reactivex/disposables/Disposable;->dispose()V .line 80 invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object p0 sget-object p1, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper; if-eq p0, p1, :cond_0 .line 81 invoke-static {}, Lio/reactivex/internal/disposables/DisposableHelper;->reportDisposableSet()V :cond_0 const/4 p0, 0x0 return p0 :cond_1 const/4 p0, 0x1 return p0 .end method .method public static trySet(Ljava/util/concurrent/atomic/AtomicReference;Lio/reactivex/disposables/Disposable;)Z .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/concurrent/atomic/AtomicReference<", "Lio/reactivex/disposables/Disposable;", ">;", "Lio/reactivex/disposables/Disposable;", ")Z" } .end annotation const/4 v0, 0x0 .line 166 invoke-virtual {p0, v0, p1}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z move-result v0 if-nez v0, :cond_1 .line 167 invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object p0 sget-object v0, Lio/reactivex/internal/disposables/DisposableHelper;->DISPOSED:Lio/reactivex/internal/disposables/DisposableHelper; if-ne p0, v0, :cond_0 .line 168 invoke-interface {p1}, Lio/reactivex/disposables/Disposable;->dispose()V :cond_0 const/4 p0, 0x0 return p0 :cond_1 const/4 p0, 0x1 return p0 .end method .method public static validate(Lio/reactivex/disposables/Disposable;Lio/reactivex/disposables/Disposable;)Z .locals 1 const/4 v0, 0x0 if-nez p1, :cond_0 .line 140 new-instance p0, Ljava/lang/NullPointerException; const-string p1, "next is null" invoke-direct {p0, p1}, Ljava/lang/NullPointerException;->(Ljava/lang/String;)V invoke-static {p0}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V return v0 :cond_0 if-eqz p0, :cond_1 .line 144 invoke-interface {p1}, Lio/reactivex/disposables/Disposable;->dispose()V .line 145 invoke-static {}, Lio/reactivex/internal/disposables/DisposableHelper;->reportDisposableSet()V return v0 :cond_1 const/4 p0, 0x1 return p0 .end method .method public static valueOf(Ljava/lang/String;)Lio/reactivex/internal/disposables/DisposableHelper; .locals 1 .line 25 const-class v0, Lio/reactivex/internal/disposables/DisposableHelper; invoke-static {v0, p0}, Ljava/lang/Enum;->valueOf(Ljava/lang/Class;Ljava/lang/String;)Ljava/lang/Enum; move-result-object p0 check-cast p0, Lio/reactivex/internal/disposables/DisposableHelper; return-object p0 .end method .method public static values()[Lio/reactivex/internal/disposables/DisposableHelper; .locals 1 .line 25 sget-object v0, Lio/reactivex/internal/disposables/DisposableHelper;->$VALUES:[Lio/reactivex/internal/disposables/DisposableHelper; invoke-virtual {v0}, [Lio/reactivex/internal/disposables/DisposableHelper;->clone()Ljava/lang/Object; move-result-object v0 check-cast v0, [Lio/reactivex/internal/disposables/DisposableHelper; return-object v0 .end method # virtual methods .method public dispose()V .locals 0 return-void .end method .method public isDisposed()Z .locals 1 const/4 v0, 0x1 return v0 .end method