.class public final Lcom/discord/utilities/websocket/ZLibWebSocketListener$ZLibByteStream;
.super Ljava/io/ByteArrayOutputStream;
.source "ZLibWebSocketListener.kt"


# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
    value = Lcom/discord/utilities/websocket/ZLibWebSocketListener;
.end annotation

.annotation system Ldalvik/annotation/InnerClass;
    accessFlags = 0x19
    name = "ZLibByteStream"
.end annotation

.annotation system Ldalvik/annotation/MemberClasses;
    value = {
        Lcom/discord/utilities/websocket/ZLibWebSocketListener$ZLibByteStream$Companion;
    }
.end annotation


# static fields
.field public static final Companion:Lcom/discord/utilities/websocket/ZLibWebSocketListener$ZLibByteStream$Companion;

.field public static final INFLATE_BUFFER_SIZE:I = 0x1000

.field public static final INITIAL_BUFFER_SIZE_MULTIPLIER:I = 0x2

.field public static final UTF8_DECODER:Ljava/nio/charset/CharsetDecoder;


# direct methods
.method public static constructor <clinit>()V
    .locals 2

    new-instance v0, Lcom/discord/utilities/websocket/ZLibWebSocketListener$ZLibByteStream$Companion;

    const/4 v1, 0x0

    invoke-direct {v0, v1}, Lcom/discord/utilities/websocket/ZLibWebSocketListener$ZLibByteStream$Companion;-><init>(Lkotlin/jvm/internal/DefaultConstructorMarker;)V

    sput-object v0, Lcom/discord/utilities/websocket/ZLibWebSocketListener$ZLibByteStream;->Companion:Lcom/discord/utilities/websocket/ZLibWebSocketListener$ZLibByteStream$Companion;

    const-string v0, "UTF-8"

    invoke-static {v0}, Ljava/nio/charset/Charset;->forName(Ljava/lang/String;)Ljava/nio/charset/Charset;

    move-result-object v0

    invoke-virtual {v0}, Ljava/nio/charset/Charset;->newDecoder()Ljava/nio/charset/CharsetDecoder;

    move-result-object v0

    sput-object v0, Lcom/discord/utilities/websocket/ZLibWebSocketListener$ZLibByteStream;->UTF8_DECODER:Ljava/nio/charset/CharsetDecoder;

    return-void
.end method

.method public constructor <init>(Lokio/ByteString;Ljava/util/zip/Inflater;)V
    .locals 2

    const/4 v0, 0x0

    if-eqz p1, :cond_1

    if-eqz p2, :cond_0

    invoke-virtual {p1}, Lokio/ByteString;->j()I

    move-result v0

    mul-int/lit8 v0, v0, 0x2

    invoke-direct {p0, v0}, Ljava/io/ByteArrayOutputStream;-><init>(I)V

    new-instance v0, Ljava/util/zip/InflaterOutputStream;

    const/16 v1, 0x1000

    invoke-direct {v0, p0, p2, v1}, Ljava/util/zip/InflaterOutputStream;-><init>(Ljava/io/OutputStream;Ljava/util/zip/Inflater;I)V

    invoke-virtual {p1, v0}, Lokio/ByteString;->a(Ljava/io/OutputStream;)V

    invoke-virtual {v0}, Ljava/util/zip/InflaterOutputStream;->flush()V

    return-void

    :cond_0
    const-string p1, "inflater"

    invoke-static {p1}, Lw/u/b/j;->a(Ljava/lang/String;)V

    throw v0

    :cond_1
    const-string p1, "bytes"

    invoke-static {p1}, Lw/u/b/j;->a(Ljava/lang/String;)V

    throw v0
.end method


# virtual methods
.method public final toReader()Ljava/io/InputStreamReader;
    .locals 5

    new-instance v0, Ljava/io/InputStreamReader;

    new-instance v1, Ljava/io/ByteArrayInputStream;

    iget-object v2, p0, Ljava/io/ByteArrayOutputStream;->buf:[B

    iget v3, p0, Ljava/io/ByteArrayOutputStream;->count:I

    const/4 v4, 0x0

    invoke-direct {v1, v2, v4, v3}, Ljava/io/ByteArrayInputStream;-><init>([BII)V

    sget-object v2, Lcom/discord/utilities/websocket/ZLibWebSocketListener$ZLibByteStream;->UTF8_DECODER:Ljava/nio/charset/CharsetDecoder;

    invoke-direct {v0, v1, v2}, Ljava/io/InputStreamReader;-><init>(Ljava/io/InputStream;Ljava/nio/charset/CharsetDecoder;)V

    return-object v0
.end method