l1.smali
.class public final Lio/reactivex/internal/operators/observable/l1;
.super Ljava/lang/Object;
.source "SourceFile"
# interfaces
.implements Ljava/util/concurrent/Callable;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Ljava/util/concurrent/Callable<",
"Lio/reactivex/observables/a<",
"TT;>;>;"
}
.end annotation
# instance fields
.field public final a:Lio/reactivex/l;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/l<",
"TT;>;"
}
.end annotation
.end field
.field public final b:I
.field public final c:J
.field public final d:Ljava/util/concurrent/TimeUnit;
.field public final e:Lio/reactivex/t;
# direct methods
.method public constructor <init>(Lio/reactivex/l;IJLjava/util/concurrent/TimeUnit;Lio/reactivex/t;)V
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/l<",
"TT;>;IJ",
"Ljava/util/concurrent/TimeUnit;",
"Lio/reactivex/t;",
")V"
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 2
iput-object p1, p0, Lio/reactivex/internal/operators/observable/l1;->a:Lio/reactivex/l;
.line 3
iput p2, p0, Lio/reactivex/internal/operators/observable/l1;->b:I
.line 4
iput-wide p3, p0, Lio/reactivex/internal/operators/observable/l1;->c:J
.line 5
iput-object p5, p0, Lio/reactivex/internal/operators/observable/l1;->d:Ljava/util/concurrent/TimeUnit;
.line 6
iput-object p6, p0, Lio/reactivex/internal/operators/observable/l1;->e:Lio/reactivex/t;
return-void
.end method
# virtual methods
.method public final call()Ljava/lang/Object;
.registers 7
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/Exception;
}
.end annotation
iget-object v0, p0, Lio/reactivex/internal/operators/observable/l1;->a:Lio/reactivex/l;
iget v1, p0, Lio/reactivex/internal/operators/observable/l1;->b:I
iget-wide v2, p0, Lio/reactivex/internal/operators/observable/l1;->c:J
iget-object v4, p0, Lio/reactivex/internal/operators/observable/l1;->d:Ljava/util/concurrent/TimeUnit;
iget-object v5, p0, Lio/reactivex/internal/operators/observable/l1;->e:Lio/reactivex/t;
invoke-virtual/range {v0 .. v5}, Lio/reactivex/l;->replay(IJLjava/util/concurrent/TimeUnit;Lio/reactivex/t;)Lio/reactivex/observables/a;
move-result-object v0
return-object v0
.end method