BlockingObservableIterable.smali
.class public final Lio/reactivex/internal/operators/observable/BlockingObservableIterable;
.super Ljava/lang/Object;
.source "BlockingObservableIterable.java"
# interfaces
.implements Ljava/lang/Iterable;
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lio/reactivex/internal/operators/observable/BlockingObservableIterable$BlockingObservableIterator;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Ljava/lang/Iterable<",
"TT;>;"
}
.end annotation
# instance fields
.field final bufferSize:I
.field final source:Lio/reactivex/ObservableSource;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/ObservableSource<",
"+TT;>;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method public constructor <init>(Lio/reactivex/ObservableSource;I)V
.registers 3
.param p2, "bufferSize" # I
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/ObservableSource<",
"+TT;>;I)V"
}
.end annotation
.line 31
.local p0, "this":Lio/reactivex/internal/operators/observable/BlockingObservableIterable;, "Lio/reactivex/internal/operators/observable/BlockingObservableIterable<TT;>;"
.local p1, "source":Lio/reactivex/ObservableSource;, "Lio/reactivex/ObservableSource<+TT;>;"
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 32
iput-object p1, p0, Lio/reactivex/internal/operators/observable/BlockingObservableIterable;->source:Lio/reactivex/ObservableSource;
.line 33
iput p2, p0, Lio/reactivex/internal/operators/observable/BlockingObservableIterable;->bufferSize:I
.line 34
return-void
.end method
# virtual methods
.method public iterator()Ljava/util/Iterator;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Ljava/util/Iterator<",
"TT;>;"
}
.end annotation
.line 38
.local p0, "this":Lio/reactivex/internal/operators/observable/BlockingObservableIterable;, "Lio/reactivex/internal/operators/observable/BlockingObservableIterable<TT;>;"
new-instance v0, Lio/reactivex/internal/operators/observable/BlockingObservableIterable$BlockingObservableIterator;
iget v1, p0, Lio/reactivex/internal/operators/observable/BlockingObservableIterable;->bufferSize:I
invoke-direct {v0, v1}, Lio/reactivex/internal/operators/observable/BlockingObservableIterable$BlockingObservableIterator;-><init>(I)V
.line 39
.local v0, "it":Lio/reactivex/internal/operators/observable/BlockingObservableIterable$BlockingObservableIterator;, "Lio/reactivex/internal/operators/observable/BlockingObservableIterable$BlockingObservableIterator<TT;>;"
iget-object v1, p0, Lio/reactivex/internal/operators/observable/BlockingObservableIterable;->source:Lio/reactivex/ObservableSource;
invoke-interface {v1, v0}, Lio/reactivex/ObservableSource;->subscribe(Lio/reactivex/Observer;)V
.line 40
return-object v0
.end method