StreamedRequestBody.smali

.class final Lokhttp3/internal/huc/StreamedRequestBody;
.super Lokhttp3/internal/huc/OutputStreamRequestBody;
.source "SourceFile"

# interfaces
.implements Lokhttp3/internal/http/UnrepeatableRequestBody;


# instance fields
.field private final pipe:Lokio/o;


# direct methods
.method public constructor <init>(J)V
    .registers 5

    .line 1
    invoke-direct {p0}, Lokhttp3/internal/huc/OutputStreamRequestBody;-><init>()V

    .line 2
    new-instance v0, Lokio/o;

    invoke-direct {v0}, Lokio/o;-><init>()V

    iput-object v0, p0, Lokhttp3/internal/huc/StreamedRequestBody;->pipe:Lokio/o;

    .line 3
    iget-object v0, v0, Lokio/o;->e:Lokio/o$a;

    .line 4
    sget-object v1, Lokio/k;->a:Ljava/util/logging/Logger;

    .line 5
    new-instance v1, Lokio/q;

    invoke-direct {v1, v0}, Lokio/q;-><init>(Lokio/v;)V

    .line 6
    invoke-virtual {p0, v1, p1, p2}, Lokhttp3/internal/huc/OutputStreamRequestBody;->initOutputStream(Lokio/c;J)V

    return-void
.end method


# virtual methods
.method public writeTo(Lokio/c;)V
    .registers 8
    .annotation system Ldalvik/annotation/Throws;
        value = {
            Ljava/io/IOException;
        }
    .end annotation

    .line 1
    new-instance v0, Lokio/b;

    invoke-direct {v0}, Lokio/b;-><init>()V

    .line 2
    :goto_5
    iget-object v1, p0, Lokhttp3/internal/huc/StreamedRequestBody;->pipe:Lokio/o;

    .line 3
    iget-object v1, v1, Lokio/o;->f:Lokio/o$b;

    const-wide/16 v2, 0x2000

    .line 4
    invoke-virtual {v1, v0, v2, v3}, Lokio/o$b;->read(Lokio/b;J)J

    move-result-wide v1

    const-wide/16 v3, -0x1

    cmp-long v5, v1, v3

    if-eqz v5, :cond_1b

    .line 5
    iget-wide v1, v0, Lokio/b;->b:J

    .line 6
    invoke-interface {p1, v0, v1, v2}, Lokio/v;->write(Lokio/b;J)V

    goto :goto_5

    :cond_1b
    return-void
.end method