public final class io.reactivex.internal.operators.observable.ObservableIntervalRange extends io.reactivex.Observable<java.lang.Long>
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.observable.ObservableIntervalRange
super_class: io.reactivex.Observable
{
final io.reactivex.Scheduler scheduler;
descriptor: Lio/reactivex/Scheduler;
flags: (0x0010) ACC_FINAL
final long start;
descriptor: J
flags: (0x0010) ACC_FINAL
final long end;
descriptor: J
flags: (0x0010) ACC_FINAL
final long initialDelay;
descriptor: J
flags: (0x0010) ACC_FINAL
final long period;
descriptor: J
flags: (0x0010) ACC_FINAL
final java.util.concurrent.TimeUnit unit;
descriptor: Ljava/util/concurrent/TimeUnit;
flags: (0x0010) ACC_FINAL
public void <init>(long, long, long, long, java.util.concurrent.TimeUnit, io.reactivex.Scheduler);
descriptor: (JJJJLjava/util/concurrent/TimeUnit;Lio/reactivex/Scheduler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=11, args_size=7
start local 0 start local 1 start local 3 start local 5 start local 7 start local 9 start local 10 0: aload 0
invokespecial io.reactivex.Observable.<init>:()V
1: aload 0
lload 5
putfield io.reactivex.internal.operators.observable.ObservableIntervalRange.initialDelay:J
2: aload 0
lload 7
putfield io.reactivex.internal.operators.observable.ObservableIntervalRange.period:J
3: aload 0
aload 9
putfield io.reactivex.internal.operators.observable.ObservableIntervalRange.unit:Ljava/util/concurrent/TimeUnit;
4: aload 0
aload 10
putfield io.reactivex.internal.operators.observable.ObservableIntervalRange.scheduler:Lio/reactivex/Scheduler;
5: aload 0
lload 1
putfield io.reactivex.internal.operators.observable.ObservableIntervalRange.start:J
6: aload 0
lload 3
putfield io.reactivex.internal.operators.observable.ObservableIntervalRange.end:J
7: return
end local 10 end local 9 end local 7 end local 5 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactivex/internal/operators/observable/ObservableIntervalRange;
0 8 1 start J
0 8 3 end J
0 8 5 initialDelay J
0 8 7 period J
0 8 9 unit Ljava/util/concurrent/TimeUnit;
0 8 10 scheduler Lio/reactivex/Scheduler;
MethodParameters:
Name Flags
start
end
initialDelay
period
unit
scheduler
public void subscribeActual(io.reactivex.Observer<? super java.lang.Long>);
descriptor: (Lio/reactivex/Observer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=5, args_size=2
start local 0 start local 1 0: new io.reactivex.internal.operators.observable.ObservableIntervalRange$IntervalRangeObserver
dup
aload 1
aload 0
getfield io.reactivex.internal.operators.observable.ObservableIntervalRange.start:J
aload 0
getfield io.reactivex.internal.operators.observable.ObservableIntervalRange.end:J
invokespecial io.reactivex.internal.operators.observable.ObservableIntervalRange$IntervalRangeObserver.<init>:(Lio/reactivex/Observer;JJ)V
astore 2
start local 2 1: aload 1
aload 2
invokeinterface io.reactivex.Observer.onSubscribe:(Lio/reactivex/disposables/Disposable;)V
2: aload 0
getfield io.reactivex.internal.operators.observable.ObservableIntervalRange.scheduler:Lio/reactivex/Scheduler;
astore 3
start local 3 3: aload 3
instanceof io.reactivex.internal.schedulers.TrampolineScheduler
ifeq 8
4: aload 3
invokevirtual io.reactivex.Scheduler.createWorker:()Lio/reactivex/Scheduler$Worker;
astore 4
start local 4 5: aload 2
aload 4
invokevirtual io.reactivex.internal.operators.observable.ObservableIntervalRange$IntervalRangeObserver.setResource:(Lio/reactivex/disposables/Disposable;)V
6: aload 4
aload 2
aload 0
getfield io.reactivex.internal.operators.observable.ObservableIntervalRange.initialDelay:J
aload 0
getfield io.reactivex.internal.operators.observable.ObservableIntervalRange.period:J
aload 0
getfield io.reactivex.internal.operators.observable.ObservableIntervalRange.unit:Ljava/util/concurrent/TimeUnit;
invokevirtual io.reactivex.Scheduler$Worker.schedulePeriodically:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
pop
end local 4 7: goto 10
8: StackMap locals: io.reactivex.internal.operators.observable.ObservableIntervalRange$IntervalRangeObserver io.reactivex.Scheduler
StackMap stack:
aload 3
aload 2
aload 0
getfield io.reactivex.internal.operators.observable.ObservableIntervalRange.initialDelay:J
aload 0
getfield io.reactivex.internal.operators.observable.ObservableIntervalRange.period:J
aload 0
getfield io.reactivex.internal.operators.observable.ObservableIntervalRange.unit:Ljava/util/concurrent/TimeUnit;
invokevirtual io.reactivex.Scheduler.schedulePeriodicallyDirect:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
astore 4
start local 4 9: aload 2
aload 4
invokevirtual io.reactivex.internal.operators.observable.ObservableIntervalRange$IntervalRangeObserver.setResource:(Lio/reactivex/disposables/Disposable;)V
end local 4 10: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/reactivex/internal/operators/observable/ObservableIntervalRange;
0 11 1 observer Lio/reactivex/Observer<-Ljava/lang/Long;>;
1 11 2 is Lio/reactivex/internal/operators/observable/ObservableIntervalRange$IntervalRangeObserver;
3 11 3 sch Lio/reactivex/Scheduler;
5 7 4 worker Lio/reactivex/Scheduler$Worker;
9 10 4 d Lio/reactivex/disposables/Disposable;
Signature: (Lio/reactivex/Observer<-Ljava/lang/Long;>;)V
MethodParameters:
Name Flags
observer
}
Signature: Lio/reactivex/Observable<Ljava/lang/Long;>;
SourceFile: "ObservableIntervalRange.java"
NestMembers:
io.reactivex.internal.operators.observable.ObservableIntervalRange$IntervalRangeObserver
InnerClasses:
public abstract Worker = io.reactivex.Scheduler$Worker of io.reactivex.Scheduler
final IntervalRangeObserver = io.reactivex.internal.operators.observable.ObservableIntervalRange$IntervalRangeObserver of io.reactivex.internal.operators.observable.ObservableIntervalRange