OnSubscribeFromIterable.smali

.class public final Lrx/internal/operators/OnSubscribeFromIterable;
.super Ljava/lang/Object;
.source "OnSubscribeFromIterable.java"

# interfaces
.implements Lrx/f;


# annotations
.annotation system Ldalvik/annotation/Signature;
    value = {
        "<T:",
        "Ljava/lang/Object;",
        ">",
        "Ljava/lang/Object;",
        "Lrx/f",
        "<TT;>;"
    }
.end annotation


# virtual methods
.method public final synthetic call(Ljava/lang/Object;)V
    .registers 5

    .prologue
    .line 34
    check-cast p1, Lrx/o;

    .line 1051
    const/4 v0, 0x0

    :try_start_3
    invoke-interface {v0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;

    move-result-object v0

    .line 1053
    invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
    :try_end_a
    .catch Ljava/lang/Throwable; {:try_start_3 .. :try_end_a} :catch_17

    move-result v1

    .line 1059
    invoke-virtual {p1}, Lrx/o;->isUnsubscribed()Z

    move-result v2

    if-nez v2, :cond_16

    .line 1060
    if-nez v1, :cond_1c

    .line 1061
    invoke-virtual {p1}, Lrx/o;->SG()V

    :cond_16
    :goto_16
    return-void

    .line 1055
    :catch_17
    move-exception v0

    invoke-static {v0, p1}, Lrx/exceptions/d;->a(Ljava/lang/Throwable;Lrx/h;)V

    goto :goto_16

    .line 1063
    :cond_1c
    new-instance v1, Lrx/internal/operators/OnSubscribeFromIterable$IterableProducer;

    invoke-direct {v1, p1, v0}, Lrx/internal/operators/OnSubscribeFromIterable$IterableProducer;-><init>(Lrx/o;Ljava/util/Iterator;)V

    invoke-virtual {p1, v1}, Lrx/o;->a(Lrx/i;)V

    goto :goto_16
.end method