gb.smali
.class public final Lio/reactivex/internal/operators/observable/gb;
.super Lio/reactivex/internal/operators/observable/a;
.source "ObservableTimeInterval.java"
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/internal/operators/observable/a",
"<TT;",
"Lio/reactivex/e/j",
"<TT;>;>;"
}
.end annotation
# instance fields
.field private unit:Ljava/util/concurrent/TimeUnit;
# direct methods
.method public constructor <init>(Lio/reactivex/p;Ljava/util/concurrent/TimeUnit;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/p",
"<TT;>;",
"Ljava/util/concurrent/TimeUnit;",
")V"
}
.end annotation
.prologue
.line 28
invoke-direct {p0, p1}, Lio/reactivex/internal/operators/observable/a;-><init>(Lio/reactivex/p;)V
.line 30
iput-object p2, p0, Lio/reactivex/internal/operators/observable/gb;->unit:Ljava/util/concurrent/TimeUnit;
.line 31
return-void
.end method
# virtual methods
.method public final subscribeActual(Lio/reactivex/r;)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/r",
"<-",
"Lio/reactivex/e/j",
"<TT;>;>;)V"
}
.end annotation
.prologue
.line 35
iget-object v0, p0, Lio/reactivex/internal/operators/observable/gb;->source:Lio/reactivex/p;
new-instance v1, Lio/reactivex/internal/operators/observable/gc;
iget-object v2, p0, Lio/reactivex/internal/operators/observable/gb;->unit:Ljava/util/concurrent/TimeUnit;
invoke-direct {v1, p1, v2}, Lio/reactivex/internal/operators/observable/gc;-><init>(Lio/reactivex/r;Ljava/util/concurrent/TimeUnit;)V
invoke-interface {v0, v1}, Lio/reactivex/p;->subscribe(Lio/reactivex/r;)V
.line 36
return-void
.end method