OperatorMerge.smali
.class public final Lrx/internal/operators/OperatorMerge;
.super Ljava/lang/Object;
.source "OperatorMerge.java"
# interfaces
.implements Lrx/g;
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/lang/Object;",
"Lrx/g",
"<TT;",
"Lrx/e",
"<+TT;>;>;"
}
.end annotation
# instance fields
.field private caL:I
# direct methods
.method constructor <init>()V
.registers 2
.prologue
.line 99
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 101
const v0, 0x7fffffff
iput v0, p0, Lrx/internal/operators/OperatorMerge;->caL:I
.line 102
return-void
.end method
.method private b(Lrx/o;)Lrx/o;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/o",
"<-TT;>;)",
"Lrx/o",
"<",
"Lrx/e",
"<+TT;>;>;"
}
.end annotation
.prologue
.line 106
new-instance v0, Lrx/internal/operators/s;
iget v1, p0, Lrx/internal/operators/OperatorMerge;->caL:I
invoke-direct {v0, p1, v1}, Lrx/internal/operators/s;-><init>(Lrx/o;I)V
.line 107
new-instance v1, Lrx/internal/operators/OperatorMerge$MergeProducer;
invoke-direct {v1, v0}, Lrx/internal/operators/OperatorMerge$MergeProducer;-><init>(Lrx/internal/operators/s;)V
.line 108
iput-object v1, v0, Lrx/internal/operators/s;->caR:Lrx/internal/operators/OperatorMerge$MergeProducer;
.line 110
invoke-virtual {p1, v0}, Lrx/o;->add(Lrx/p;)V
.line 111
invoke-virtual {p1, v1}, Lrx/o;->a(Lrx/i;)V
.line 113
return-object v0
.end method
# virtual methods
.method public final synthetic call(Ljava/lang/Object;)Ljava/lang/Object;
.registers 3
.prologue
.line 55
check-cast p1, Lrx/o;
invoke-direct {p0, p1}, Lrx/internal/operators/OperatorMerge;->b(Lrx/o;)Lrx/o;
move-result-object v0
return-object v0
.end method