OperatorOnErrorResumeNextViaFunction.smali
.class public final Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;
.super Ljava/lang/Object;
.source "OperatorOnErrorResumeNextViaFunction.java"
# interfaces
.implements Lrx/Observable$Operator;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lrx/Observable$Operator<",
"TT;TT;>;"
}
.end annotation
# instance fields
.field final resumeFunction:Lrx/functions/Func1;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/functions/Func1<",
"-",
"Ljava/lang/Throwable;",
"+",
"Lrx/Observable<",
"+TT;>;>;"
}
.end annotation
.end field
# direct methods
.method public constructor <init>(Lrx/functions/Func1;)V
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/functions/Func1<",
"-",
"Ljava/lang/Throwable;",
"+",
"Lrx/Observable<",
"+TT;>;>;)V"
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 2
iput-object p1, p0, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;->resumeFunction:Lrx/functions/Func1;
return-void
.end method
.method public static withException(Lrx/Observable;)Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lrx/Observable<",
"+TT;>;)",
"Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction<",
"TT;>;"
}
.end annotation
.line 1
new-instance v0, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;
new-instance v1, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction$3;
invoke-direct {v1, p0}, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction$3;-><init>(Lrx/Observable;)V
invoke-direct {v0, v1}, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;-><init>(Lrx/functions/Func1;)V
return-object v0
.end method
.method public static withOther(Lrx/Observable;)Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lrx/Observable<",
"+TT;>;)",
"Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction<",
"TT;>;"
}
.end annotation
.line 1
new-instance v0, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;
new-instance v1, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction$2;
invoke-direct {v1, p0}, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction$2;-><init>(Lrx/Observable;)V
invoke-direct {v0, v1}, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;-><init>(Lrx/functions/Func1;)V
return-object v0
.end method
.method public static withSingle(Lrx/functions/Func1;)Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lrx/functions/Func1<",
"-",
"Ljava/lang/Throwable;",
"+TT;>;)",
"Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction<",
"TT;>;"
}
.end annotation
.line 1
new-instance v0, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;
new-instance v1, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction$1;
invoke-direct {v1, p0}, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction$1;-><init>(Lrx/functions/Func1;)V
invoke-direct {v0, v1}, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;-><init>(Lrx/functions/Func1;)V
return-object v0
.end method
# virtual methods
.method public bridge synthetic call(Ljava/lang/Object;)Ljava/lang/Object;
.registers 2
.line 1
check-cast p1, Lrx/Subscriber;
invoke-virtual {p0, p1}, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;->call(Lrx/Subscriber;)Lrx/Subscriber;
move-result-object p1
return-object p1
.end method
.method public call(Lrx/Subscriber;)Lrx/Subscriber;
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/Subscriber<",
"-TT;>;)",
"Lrx/Subscriber<",
"-TT;>;"
}
.end annotation
.line 2
new-instance v0, Lrx/internal/producers/ProducerArbiter;
invoke-direct {v0}, Lrx/internal/producers/ProducerArbiter;-><init>()V
.line 3
new-instance v1, Lrx/subscriptions/SerialSubscription;
invoke-direct {v1}, Lrx/subscriptions/SerialSubscription;-><init>()V
.line 4
new-instance v2, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction$4;
invoke-direct {v2, p0, p1, v0, v1}, Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction$4;-><init>(Lrx/internal/operators/OperatorOnErrorResumeNextViaFunction;Lrx/Subscriber;Lrx/internal/producers/ProducerArbiter;Lrx/subscriptions/SerialSubscription;)V
.line 5
invoke-virtual {v1, v2}, Lrx/subscriptions/SerialSubscription;->set(Lrx/Subscription;)V
.line 6
invoke-virtual {p1, v1}, Lrx/Subscriber;->add(Lrx/Subscription;)V
.line 7
invoke-virtual {p1, v0}, Lrx/Subscriber;->setProducer(Lrx/Producer;)V
return-object v2
.end method