public final class okhttp3.internal.ws.RealWebSocket implements okhttp3.WebSocket, okhttp3.internal.ws.WebSocketReader$FrameCallback
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: okhttp3.internal.ws.RealWebSocket
  super_class: java.lang.Object
{
  private static final java.util.List<okhttp3.Protocol> ONLY_HTTP1;
    descriptor: Ljava/util/List;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/List<Lokhttp3/Protocol;>;

  private static final long MAX_QUEUE_SIZE;
    descriptor: J
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 16777216

  private static final long CANCEL_AFTER_CLOSE_MILLIS;
    descriptor: J
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 60000

  private final okhttp3.Request originalRequest;
    descriptor: Lokhttp3/Request;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  final okhttp3.WebSocketListener listener;
    descriptor: Lokhttp3/WebSocketListener;
    flags: (0x0010) ACC_FINAL

  private final java.util.Random random;
    descriptor: Ljava/util/Random;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final long pingIntervalMillis;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.lang.String key;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private okhttp3.Call call;
    descriptor: Lokhttp3/Call;
    flags: (0x0002) ACC_PRIVATE

  private final java.lang.Runnable writerRunnable;
    descriptor: Ljava/lang/Runnable;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private okhttp3.internal.ws.WebSocketReader reader;
    descriptor: Lokhttp3/internal/ws/WebSocketReader;
    flags: (0x0002) ACC_PRIVATE

  private okhttp3.internal.ws.WebSocketWriter writer;
    descriptor: Lokhttp3/internal/ws/WebSocketWriter;
    flags: (0x0002) ACC_PRIVATE

  private java.util.concurrent.ScheduledExecutorService executor;
    descriptor: Ljava/util/concurrent/ScheduledExecutorService;
    flags: (0x0002) ACC_PRIVATE

  private okhttp3.internal.ws.RealWebSocket$Streams streams;
    descriptor: Lokhttp3/internal/ws/RealWebSocket$Streams;
    flags: (0x0002) ACC_PRIVATE

  private final java.util.ArrayDeque<okio.ByteString> pongQueue;
    descriptor: Ljava/util/ArrayDeque;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/ArrayDeque<Lokio/ByteString;>;

  private final java.util.ArrayDeque<java.lang.Object> messageAndCloseQueue;
    descriptor: Ljava/util/ArrayDeque;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/ArrayDeque<Ljava/lang/Object;>;

  private long queueSize;
    descriptor: J
    flags: (0x0002) ACC_PRIVATE

  private boolean enqueuedClose;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private java.util.concurrent.ScheduledFuture<?> cancelFuture;
    descriptor: Ljava/util/concurrent/ScheduledFuture;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/concurrent/ScheduledFuture<*>;

  private int receivedCloseCode;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private java.lang.String receivedCloseReason;
    descriptor: Ljava/lang/String;
    flags: (0x0002) ACC_PRIVATE

  private boolean failed;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private int sentPingCount;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private int receivedPingCount;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private int receivedPongCount;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private boolean awaitingPong;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 56
            ldc Lokhttp3/internal/ws/RealWebSocket;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic okhttp3.internal.ws.RealWebSocket.$assertionsDisabled:Z
         3: .line 57
            getstatic okhttp3.Protocol.HTTP_1_1:Lokhttp3/Protocol;
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            putstatic okhttp3.internal.ws.RealWebSocket.ONLY_HTTP1:Ljava/util/List;
         4: .line 69
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(okhttp3.Request, okhttp3.WebSocketListener, java.util.Random, long);
    descriptor: (Lokhttp3/Request;Lokhttp3/WebSocketListener;Ljava/util/Random;J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=7, args_size=5
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // okhttp3.Request request
        start local 2 // okhttp3.WebSocketListener listener
        start local 3 // java.util.Random random
        start local 4 // long pingIntervalMillis
         0: .line 142
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 104
            aload 0 /* this */
            new java.util.ArrayDeque
            dup
            invokespecial java.util.ArrayDeque.<init>:()V
            putfield okhttp3.internal.ws.RealWebSocket.pongQueue:Ljava/util/ArrayDeque;
         2: .line 107
            aload 0 /* this */
            new java.util.ArrayDeque
            dup
            invokespecial java.util.ArrayDeque.<init>:()V
            putfield okhttp3.internal.ws.RealWebSocket.messageAndCloseQueue:Ljava/util/ArrayDeque;
         3: .line 122
            aload 0 /* this */
            iconst_m1
            putfield okhttp3.internal.ws.RealWebSocket.receivedCloseCode:I
         4: .line 144
            ldc "GET"
            aload 1 /* request */
            invokevirtual okhttp3.Request.method:()Ljava/lang/String;
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifne 6
         5: .line 145
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Request must be GET: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* request */
            invokevirtual okhttp3.Request.method:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 147
      StackMap locals: okhttp3.internal.ws.RealWebSocket okhttp3.Request okhttp3.WebSocketListener java.util.Random long
      StackMap stack:
            aload 0 /* this */
            aload 1 /* request */
            putfield okhttp3.internal.ws.RealWebSocket.originalRequest:Lokhttp3/Request;
         7: .line 148
            aload 0 /* this */
            aload 2 /* listener */
            putfield okhttp3.internal.ws.RealWebSocket.listener:Lokhttp3/WebSocketListener;
         8: .line 149
            aload 0 /* this */
            aload 3 /* random */
            putfield okhttp3.internal.ws.RealWebSocket.random:Ljava/util/Random;
         9: .line 150
            aload 0 /* this */
            lload 4 /* pingIntervalMillis */
            putfield okhttp3.internal.ws.RealWebSocket.pingIntervalMillis:J
        10: .line 152
            bipush 16
            newarray 8
            astore 6 /* nonce */
        start local 6 // byte[] nonce
        11: .line 153
            aload 3 /* random */
            aload 6 /* nonce */
            invokevirtual java.util.Random.nextBytes:([B)V
        12: .line 154
            aload 0 /* this */
            aload 6 /* nonce */
            invokestatic okio.ByteString.of:([B)Lokio/ByteString;
            invokevirtual okio.ByteString.base64:()Ljava/lang/String;
            putfield okhttp3.internal.ws.RealWebSocket.key:Ljava/lang/String;
        13: .line 156
            aload 0 /* this */
            new okhttp3.internal.ws.RealWebSocket$1
            dup
            aload 0 /* this */
            invokespecial okhttp3.internal.ws.RealWebSocket$1.<init>:(Lokhttp3/internal/ws/RealWebSocket;)V
            putfield okhttp3.internal.ws.RealWebSocket.writerRunnable:Ljava/lang/Runnable;
        14: .line 166
            return
        end local 6 // byte[] nonce
        end local 4 // long pingIntervalMillis
        end local 3 // java.util.Random random
        end local 2 // okhttp3.WebSocketListener listener
        end local 1 // okhttp3.Request request
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   15     0                this  Lokhttp3/internal/ws/RealWebSocket;
            0   15     1             request  Lokhttp3/Request;
            0   15     2            listener  Lokhttp3/WebSocketListener;
            0   15     3              random  Ljava/util/Random;
            0   15     4  pingIntervalMillis  J
           11   15     6               nonce  [B
    MethodParameters:
                    Name  Flags
      request             
      listener            
      random              
      pingIntervalMillis  

  public okhttp3.Request request();
    descriptor: ()Lokhttp3/Request;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 169
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.originalRequest:Lokhttp3/Request;
            areturn
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lokhttp3/internal/ws/RealWebSocket;

  public synchronized long queueSize();
    descriptor: ()J
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 173
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.queueSize:J
            lreturn
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lokhttp3/internal/ws/RealWebSocket;

  public void cancel();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 177
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.call:Lokhttp3/Call;
            invokeinterface okhttp3.Call.cancel:()V
         1: .line 178
            return
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lokhttp3/internal/ws/RealWebSocket;

  public void connect(okhttp3.OkHttpClient);
    descriptor: (Lokhttp3/OkHttpClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // okhttp3.OkHttpClient client
         0: .line 181
            aload 1 /* client */
            invokevirtual okhttp3.OkHttpClient.newBuilder:()Lokhttp3/OkHttpClient$Builder;
         1: .line 182
            getstatic okhttp3.EventListener.NONE:Lokhttp3/EventListener;
            invokevirtual okhttp3.OkHttpClient$Builder.eventListener:(Lokhttp3/EventListener;)Lokhttp3/OkHttpClient$Builder;
         2: .line 183
            getstatic okhttp3.internal.ws.RealWebSocket.ONLY_HTTP1:Ljava/util/List;
            invokevirtual okhttp3.OkHttpClient$Builder.protocols:(Ljava/util/List;)Lokhttp3/OkHttpClient$Builder;
         3: .line 184
            invokevirtual okhttp3.OkHttpClient$Builder.build:()Lokhttp3/OkHttpClient;
         4: .line 181
            astore 1 /* client */
         5: .line 185
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.originalRequest:Lokhttp3/Request;
            invokevirtual okhttp3.Request.newBuilder:()Lokhttp3/Request$Builder;
         6: .line 186
            ldc "Upgrade"
            ldc "websocket"
            invokevirtual okhttp3.Request$Builder.header:(Ljava/lang/String;Ljava/lang/String;)Lokhttp3/Request$Builder;
         7: .line 187
            ldc "Connection"
            ldc "Upgrade"
            invokevirtual okhttp3.Request$Builder.header:(Ljava/lang/String;Ljava/lang/String;)Lokhttp3/Request$Builder;
         8: .line 188
            ldc "Sec-WebSocket-Key"
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.key:Ljava/lang/String;
            invokevirtual okhttp3.Request$Builder.header:(Ljava/lang/String;Ljava/lang/String;)Lokhttp3/Request$Builder;
         9: .line 189
            ldc "Sec-WebSocket-Version"
            ldc "13"
            invokevirtual okhttp3.Request$Builder.header:(Ljava/lang/String;Ljava/lang/String;)Lokhttp3/Request$Builder;
        10: .line 190
            invokevirtual okhttp3.Request$Builder.build:()Lokhttp3/Request;
        11: .line 185
            astore 2 /* request */
        start local 2 // okhttp3.Request request
        12: .line 191
            aload 0 /* this */
            getstatic okhttp3.internal.Internal.instance:Lokhttp3/internal/Internal;
            aload 1 /* client */
            aload 2 /* request */
            invokevirtual okhttp3.internal.Internal.newWebSocketCall:(Lokhttp3/OkHttpClient;Lokhttp3/Request;)Lokhttp3/Call;
            putfield okhttp3.internal.ws.RealWebSocket.call:Lokhttp3/Call;
        13: .line 192
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.call:Lokhttp3/Call;
            invokeinterface okhttp3.Call.timeout:()Lokio/Timeout;
            invokevirtual okio.Timeout.clearTimeout:()Lokio/Timeout;
            pop
        14: .line 193
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.call:Lokhttp3/Call;
            new okhttp3.internal.ws.RealWebSocket$2
            dup
            aload 0 /* this */
            aload 2 /* request */
            invokespecial okhttp3.internal.ws.RealWebSocket$2.<init>:(Lokhttp3/internal/ws/RealWebSocket;Lokhttp3/Request;)V
            invokeinterface okhttp3.Call.enqueue:(Lokhttp3/Callback;)V
        15: .line 224
            return
        end local 2 // okhttp3.Request request
        end local 1 // okhttp3.OkHttpClient client
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   16     0     this  Lokhttp3/internal/ws/RealWebSocket;
            0   16     1   client  Lokhttp3/OkHttpClient;
           12   16     2  request  Lokhttp3/Request;
    MethodParameters:
        Name  Flags
      client  

  void checkResponse(okhttp3.Response);
    descriptor: (Lokhttp3/Response;)V
    flags: (0x0000) 
    Code:
      stack=5, locals=6, args_size=2
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // okhttp3.Response response
         0: .line 227
            aload 1 /* response */
            invokevirtual okhttp3.Response.code:()I
            bipush 101
            if_icmpeq 4
         1: .line 228
            new java.net.ProtocolException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Expected HTTP 101 response but was '"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
         2: .line 229
            aload 1 /* response */
            invokevirtual okhttp3.Response.code:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* response */
            invokevirtual okhttp3.Response.message:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "'"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         3: .line 228
            invokespecial java.net.ProtocolException.<init>:(Ljava/lang/String;)V
            athrow
         4: .line 232
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            ldc "Connection"
            invokevirtual okhttp3.Response.header:(Ljava/lang/String;)Ljava/lang/String;
            astore 2 /* headerConnection */
        start local 2 // java.lang.String headerConnection
         5: .line 233
            ldc "Upgrade"
            aload 2 /* headerConnection */
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifne 9
         6: .line 234
            new java.net.ProtocolException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Expected 'Connection' header value 'Upgrade' but was '"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
         7: .line 235
            aload 2 /* headerConnection */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "'"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         8: .line 234
            invokespecial java.net.ProtocolException.<init>:(Ljava/lang/String;)V
            athrow
         9: .line 238
      StackMap locals: java.lang.String
      StackMap stack:
            aload 1 /* response */
            ldc "Upgrade"
            invokevirtual okhttp3.Response.header:(Ljava/lang/String;)Ljava/lang/String;
            astore 3 /* headerUpgrade */
        start local 3 // java.lang.String headerUpgrade
        10: .line 239
            ldc "websocket"
            aload 3 /* headerUpgrade */
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifne 14
        11: .line 240
            new java.net.ProtocolException
            dup
        12: .line 241
            new java.lang.StringBuilder
            dup
            ldc "Expected 'Upgrade' header value 'websocket' but was '"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 3 /* headerUpgrade */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "'"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
        13: .line 240
            invokespecial java.net.ProtocolException.<init>:(Ljava/lang/String;)V
            athrow
        14: .line 244
      StackMap locals: java.lang.String
      StackMap stack:
            aload 1 /* response */
            ldc "Sec-WebSocket-Accept"
            invokevirtual okhttp3.Response.header:(Ljava/lang/String;)Ljava/lang/String;
            astore 4 /* headerAccept */
        start local 4 // java.lang.String headerAccept
        15: .line 245
            new java.lang.StringBuilder
            dup
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.key:Ljava/lang/String;
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokestatic okio.ByteString.encodeUtf8:(Ljava/lang/String;)Lokio/ByteString;
        16: .line 246
            invokevirtual okio.ByteString.sha1:()Lokio/ByteString;
            invokevirtual okio.ByteString.base64:()Ljava/lang/String;
        17: .line 245
            astore 5 /* acceptExpected */
        start local 5 // java.lang.String acceptExpected
        18: .line 247
            aload 5 /* acceptExpected */
            aload 4 /* headerAccept */
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifne 22
        19: .line 248
            new java.net.ProtocolException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Expected 'Sec-WebSocket-Accept' header value '"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
        20: .line 249
            aload 5 /* acceptExpected */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "' but was '"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 4 /* headerAccept */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc "'"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
        21: .line 248
            invokespecial java.net.ProtocolException.<init>:(Ljava/lang/String;)V
            athrow
        22: .line 251
      StackMap locals: java.lang.String java.lang.String
      StackMap stack:
            return
        end local 5 // java.lang.String acceptExpected
        end local 4 // java.lang.String headerAccept
        end local 3 // java.lang.String headerUpgrade
        end local 2 // java.lang.String headerConnection
        end local 1 // okhttp3.Response response
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   23     0              this  Lokhttp3/internal/ws/RealWebSocket;
            0   23     1          response  Lokhttp3/Response;
            5   23     2  headerConnection  Ljava/lang/String;
           10   23     3     headerUpgrade  Ljava/lang/String;
           15   23     4      headerAccept  Ljava/lang/String;
           18   23     5    acceptExpected  Ljava/lang/String;
    Exceptions:
      throws java.net.ProtocolException
    MethodParameters:
          Name  Flags
      response  

  public void initReaderAndWriter(java.lang.String, okhttp3.internal.ws.RealWebSocket$Streams);
    descriptor: (Ljava/lang/String;Lokhttp3/internal/ws/RealWebSocket$Streams;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=4, args_size=3
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // java.lang.String name
        start local 2 // okhttp3.internal.ws.RealWebSocket$Streams streams
         0: .line 254
            aload 0 /* this */
            dup
            astore 3
            monitorenter
         1: .line 255
            aload 0 /* this */
            aload 2 /* streams */
            putfield okhttp3.internal.ws.RealWebSocket.streams:Lokhttp3/internal/ws/RealWebSocket$Streams;
         2: .line 256
            aload 0 /* this */
            new okhttp3.internal.ws.WebSocketWriter
            dup
            aload 2 /* streams */
            getfield okhttp3.internal.ws.RealWebSocket$Streams.client:Z
            aload 2 /* streams */
            getfield okhttp3.internal.ws.RealWebSocket$Streams.sink:Lokio/BufferedSink;
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.random:Ljava/util/Random;
            invokespecial okhttp3.internal.ws.WebSocketWriter.<init>:(ZLokio/BufferedSink;Ljava/util/Random;)V
            putfield okhttp3.internal.ws.RealWebSocket.writer:Lokhttp3/internal/ws/WebSocketWriter;
         3: .line 257
            aload 0 /* this */
            new java.util.concurrent.ScheduledThreadPoolExecutor
            dup
            iconst_1
            aload 1 /* name */
            iconst_0
            invokestatic okhttp3.internal.Util.threadFactory:(Ljava/lang/String;Z)Ljava/util/concurrent/ThreadFactory;
            invokespecial java.util.concurrent.ScheduledThreadPoolExecutor.<init>:(ILjava/util/concurrent/ThreadFactory;)V
            putfield okhttp3.internal.ws.RealWebSocket.executor:Ljava/util/concurrent/ScheduledExecutorService;
         4: .line 258
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.pingIntervalMillis:J
            lconst_0
            lcmp
            ifeq 8
         5: .line 259
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.executor:Ljava/util/concurrent/ScheduledExecutorService;
         6: .line 260
            new okhttp3.internal.ws.RealWebSocket$PingRunnable
            dup
            aload 0 /* this */
            invokespecial okhttp3.internal.ws.RealWebSocket$PingRunnable.<init>:(Lokhttp3/internal/ws/RealWebSocket;)V
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.pingIntervalMillis:J
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.pingIntervalMillis:J
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
         7: .line 259
            invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
            pop
         8: .line 262
      StackMap locals: okhttp3.internal.ws.RealWebSocket
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.messageAndCloseQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.isEmpty:()Z
            ifne 10
         9: .line 263
            aload 0 /* this */
            invokevirtual okhttp3.internal.ws.RealWebSocket.runWriter:()V
        10: .line 254
      StackMap locals:
      StackMap stack:
            aload 3
            monitorexit
        11: goto 14
      StackMap locals:
      StackMap stack: java.lang.Throwable
        12: aload 3
            monitorexit
        13: athrow
        14: .line 267
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new okhttp3.internal.ws.WebSocketReader
            dup
            aload 2 /* streams */
            getfield okhttp3.internal.ws.RealWebSocket$Streams.client:Z
            aload 2 /* streams */
            getfield okhttp3.internal.ws.RealWebSocket$Streams.source:Lokio/BufferedSource;
            aload 0 /* this */
            invokespecial okhttp3.internal.ws.WebSocketReader.<init>:(ZLokio/BufferedSource;Lokhttp3/internal/ws/WebSocketReader$FrameCallback;)V
            putfield okhttp3.internal.ws.RealWebSocket.reader:Lokhttp3/internal/ws/WebSocketReader;
        15: .line 268
            return
        end local 2 // okhttp3.internal.ws.RealWebSocket$Streams streams
        end local 1 // java.lang.String name
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   16     0     this  Lokhttp3/internal/ws/RealWebSocket;
            0   16     1     name  Ljava/lang/String;
            0   16     2  streams  Lokhttp3/internal/ws/RealWebSocket$Streams;
      Exception table:
        from    to  target  type
           1    11      12  any
          12    13      12  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
         Name  Flags
      name     
      streams  

  public void loopReader();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 272
            goto 2
         1: .line 274
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.reader:Lokhttp3/internal/ws/WebSocketReader;
            invokevirtual okhttp3.internal.ws.WebSocketReader.processNextFrame:()V
         2: .line 272
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.receivedCloseCode:I
            iconst_m1
            if_icmpeq 1
         3: .line 276
            return
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lokhttp3/internal/ws/RealWebSocket;
    Exceptions:
      throws java.io.IOException

  boolean processNextFrame();
    descriptor: ()Z
    flags: (0x0000) 
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 284
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.reader:Lokhttp3/internal/ws/WebSocketReader;
            invokevirtual okhttp3.internal.ws.WebSocketReader.processNextFrame:()V
         1: .line 285
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.receivedCloseCode:I
            iconst_m1
            if_icmpne 2
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         2: iconst_0
         3: ireturn
         4: .line 286
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 1 /* e */
        start local 1 // java.lang.Exception e
         5: .line 287
            aload 0 /* this */
            aload 1 /* e */
            aconst_null
            invokevirtual okhttp3.internal.ws.RealWebSocket.failWebSocket:(Ljava/lang/Exception;Lokhttp3/Response;)V
         6: .line 288
            iconst_0
            ireturn
        end local 1 // java.lang.Exception e
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lokhttp3/internal/ws/RealWebSocket;
            5    7     1     e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           0     3       4  Class java.lang.Exception
    Exceptions:
      throws java.io.IOException

  void awaitTermination(int, java.util.concurrent.TimeUnit);
    descriptor: (ILjava/util/concurrent/TimeUnit;)V
    flags: (0x0000) 
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // int timeout
        start local 2 // java.util.concurrent.TimeUnit timeUnit
         0: .line 296
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.executor:Ljava/util/concurrent/ScheduledExecutorService;
            iload 1 /* timeout */
            i2l
            aload 2 /* timeUnit */
            invokeinterface java.util.concurrent.ScheduledExecutorService.awaitTermination:(JLjava/util/concurrent/TimeUnit;)Z
            pop
         1: .line 297
            return
        end local 2 // java.util.concurrent.TimeUnit timeUnit
        end local 1 // int timeout
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lokhttp3/internal/ws/RealWebSocket;
            0    2     1   timeout  I
            0    2     2  timeUnit  Ljava/util/concurrent/TimeUnit;
    Exceptions:
      throws java.lang.InterruptedException
    MethodParameters:
          Name  Flags
      timeout   
      timeUnit  

  void tearDown();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 303
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.cancelFuture:Ljava/util/concurrent/ScheduledFuture;
            ifnull 2
         1: .line 304
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.cancelFuture:Ljava/util/concurrent/ScheduledFuture;
            iconst_0
            invokeinterface java.util.concurrent.ScheduledFuture.cancel:(Z)Z
            pop
         2: .line 306
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.executor:Ljava/util/concurrent/ScheduledExecutorService;
            invokeinterface java.util.concurrent.ScheduledExecutorService.shutdown:()V
         3: .line 307
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.executor:Ljava/util/concurrent/ScheduledExecutorService;
            ldc 10
            getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface java.util.concurrent.ScheduledExecutorService.awaitTermination:(JLjava/util/concurrent/TimeUnit;)Z
            pop
         4: .line 308
            return
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lokhttp3/internal/ws/RealWebSocket;
    Exceptions:
      throws java.lang.InterruptedException

  synchronized int sentPingCount();
    descriptor: ()I
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 311
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.sentPingCount:I
            ireturn
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lokhttp3/internal/ws/RealWebSocket;

  synchronized int receivedPingCount();
    descriptor: ()I
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 315
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.receivedPingCount:I
            ireturn
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lokhttp3/internal/ws/RealWebSocket;

  synchronized int receivedPongCount();
    descriptor: ()I
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 319
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.receivedPongCount:I
            ireturn
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lokhttp3/internal/ws/RealWebSocket;

  public void onReadMessage(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // java.lang.String text
         0: .line 323
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.listener:Lokhttp3/WebSocketListener;
            aload 0 /* this */
            aload 1 /* text */
            invokevirtual okhttp3.WebSocketListener.onMessage:(Lokhttp3/WebSocket;Ljava/lang/String;)V
         1: .line 324
            return
        end local 1 // java.lang.String text
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lokhttp3/internal/ws/RealWebSocket;
            0    2     1  text  Ljava/lang/String;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      text  

  public void onReadMessage(okio.ByteString);
    descriptor: (Lokio/ByteString;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // okio.ByteString bytes
         0: .line 327
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.listener:Lokhttp3/WebSocketListener;
            aload 0 /* this */
            aload 1 /* bytes */
            invokevirtual okhttp3.WebSocketListener.onMessage:(Lokhttp3/WebSocket;Lokio/ByteString;)V
         1: .line 328
            return
        end local 1 // okio.ByteString bytes
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lokhttp3/internal/ws/RealWebSocket;
            0    2     1  bytes  Lokio/ByteString;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
       Name  Flags
      bytes  

  public synchronized void onReadPing(okio.ByteString);
    descriptor: (Lokio/ByteString;)V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // okio.ByteString payload
         0: .line 332
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.failed:Z
            ifne 1
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.enqueuedClose:Z
            ifeq 2
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.messageAndCloseQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.isEmpty:()Z
            ifeq 2
      StackMap locals:
      StackMap stack:
         1: return
         2: .line 334
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.pongQueue:Ljava/util/ArrayDeque;
            aload 1 /* payload */
            invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
            pop
         3: .line 335
            aload 0 /* this */
            invokevirtual okhttp3.internal.ws.RealWebSocket.runWriter:()V
         4: .line 336
            aload 0 /* this */
            dup
            getfield okhttp3.internal.ws.RealWebSocket.receivedPingCount:I
            iconst_1
            iadd
            putfield okhttp3.internal.ws.RealWebSocket.receivedPingCount:I
         5: .line 337
            return
        end local 1 // okio.ByteString payload
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    6     0     this  Lokhttp3/internal/ws/RealWebSocket;
            0    6     1  payload  Lokio/ByteString;
    MethodParameters:
         Name  Flags
      payload  

  public synchronized void onReadPong(okio.ByteString);
    descriptor: (Lokio/ByteString;)V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // okio.ByteString buffer
         0: .line 341
            aload 0 /* this */
            dup
            getfield okhttp3.internal.ws.RealWebSocket.receivedPongCount:I
            iconst_1
            iadd
            putfield okhttp3.internal.ws.RealWebSocket.receivedPongCount:I
         1: .line 342
            aload 0 /* this */
            iconst_0
            putfield okhttp3.internal.ws.RealWebSocket.awaitingPong:Z
         2: .line 343
            return
        end local 1 // okio.ByteString buffer
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0    this  Lokhttp3/internal/ws/RealWebSocket;
            0    3     1  buffer  Lokio/ByteString;
    MethodParameters:
        Name  Flags
      buffer  

  public void onReadClose(int, java.lang.String);
    descriptor: (ILjava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=5, args_size=3
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // int code
        start local 2 // java.lang.String reason
         0: .line 346
            iload 1 /* code */
            iconst_m1
            if_icmpne 1
            new java.lang.IllegalArgumentException
            dup
            invokespecial java.lang.IllegalArgumentException.<init>:()V
            athrow
         1: .line 348
      StackMap locals:
      StackMap stack:
            aconst_null
            astore 3 /* toClose */
        start local 3 // okhttp3.internal.ws.RealWebSocket$Streams toClose
         2: .line 349
            aload 0 /* this */
            dup
            astore 4
            monitorenter
         3: .line 350
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.receivedCloseCode:I
            iconst_m1
            if_icmpeq 4
            new java.lang.IllegalStateException
            dup
            ldc "already closed"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         4: .line 351
      StackMap locals: okhttp3.internal.ws.RealWebSocket$Streams okhttp3.internal.ws.RealWebSocket
      StackMap stack:
            aload 0 /* this */
            iload 1 /* code */
            putfield okhttp3.internal.ws.RealWebSocket.receivedCloseCode:I
         5: .line 352
            aload 0 /* this */
            aload 2 /* reason */
            putfield okhttp3.internal.ws.RealWebSocket.receivedCloseReason:Ljava/lang/String;
         6: .line 353
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.enqueuedClose:Z
            ifeq 11
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.messageAndCloseQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.isEmpty:()Z
            ifeq 11
         7: .line 354
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.streams:Lokhttp3/internal/ws/RealWebSocket$Streams;
            astore 3 /* toClose */
         8: .line 355
            aload 0 /* this */
            aconst_null
            putfield okhttp3.internal.ws.RealWebSocket.streams:Lokhttp3/internal/ws/RealWebSocket$Streams;
         9: .line 356
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.cancelFuture:Ljava/util/concurrent/ScheduledFuture;
            ifnull 10
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.cancelFuture:Ljava/util/concurrent/ScheduledFuture;
            iconst_0
            invokeinterface java.util.concurrent.ScheduledFuture.cancel:(Z)Z
            pop
        10: .line 357
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.executor:Ljava/util/concurrent/ScheduledExecutorService;
            invokeinterface java.util.concurrent.ScheduledExecutorService.shutdown:()V
        11: .line 349
      StackMap locals:
      StackMap stack:
            aload 4
            monitorexit
        12: goto 15
      StackMap locals:
      StackMap stack: java.lang.Throwable
        13: aload 4
            monitorexit
        14: athrow
        15: .line 362
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.listener:Lokhttp3/WebSocketListener;
            aload 0 /* this */
            iload 1 /* code */
            aload 2 /* reason */
            invokevirtual okhttp3.WebSocketListener.onClosing:(Lokhttp3/WebSocket;ILjava/lang/String;)V
        16: .line 364
            aload 3 /* toClose */
            ifnull 22
        17: .line 365
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.listener:Lokhttp3/WebSocketListener;
            aload 0 /* this */
            iload 1 /* code */
            aload 2 /* reason */
            invokevirtual okhttp3.WebSocketListener.onClosed:(Lokhttp3/WebSocket;ILjava/lang/String;)V
        18: .line 367
            goto 22
      StackMap locals:
      StackMap stack: java.lang.Throwable
        19: astore 4
        20: .line 368
            aload 3 /* toClose */
            invokestatic okhttp3.internal.Util.closeQuietly:(Ljava/io/Closeable;)V
        21: .line 369
            aload 4
            athrow
        22: .line 368
      StackMap locals:
      StackMap stack:
            aload 3 /* toClose */
            invokestatic okhttp3.internal.Util.closeQuietly:(Ljava/io/Closeable;)V
        23: .line 370
            return
        end local 3 // okhttp3.internal.ws.RealWebSocket$Streams toClose
        end local 2 // java.lang.String reason
        end local 1 // int code
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   24     0     this  Lokhttp3/internal/ws/RealWebSocket;
            0   24     1     code  I
            0   24     2   reason  Ljava/lang/String;
            2   24     3  toClose  Lokhttp3/internal/ws/RealWebSocket$Streams;
      Exception table:
        from    to  target  type
           3    12      13  any
          13    14      13  any
          15    19      19  any
    MethodParameters:
        Name  Flags
      code    
      reason  

  public boolean send(java.lang.String);
    descriptor: (Ljava/lang/String;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // java.lang.String text
         0: .line 375
            aload 1 /* text */
            ifnonnull 1
            new java.lang.NullPointerException
            dup
            ldc "text == null"
            invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
            athrow
         1: .line 376
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* text */
            invokestatic okio.ByteString.encodeUtf8:(Ljava/lang/String;)Lokio/ByteString;
            iconst_1
            invokevirtual okhttp3.internal.ws.RealWebSocket.send:(Lokio/ByteString;I)Z
            ireturn
        end local 1 // java.lang.String text
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lokhttp3/internal/ws/RealWebSocket;
            0    2     1  text  Ljava/lang/String;
    MethodParameters:
      Name  Flags
      text  

  public boolean send(okio.ByteString);
    descriptor: (Lokio/ByteString;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // okio.ByteString bytes
         0: .line 380
            aload 1 /* bytes */
            ifnonnull 1
            new java.lang.NullPointerException
            dup
            ldc "bytes == null"
            invokespecial java.lang.NullPointerException.<init>:(Ljava/lang/String;)V
            athrow
         1: .line 381
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* bytes */
            iconst_2
            invokevirtual okhttp3.internal.ws.RealWebSocket.send:(Lokio/ByteString;I)Z
            ireturn
        end local 1 // okio.ByteString bytes
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lokhttp3/internal/ws/RealWebSocket;
            0    2     1  bytes  Lokio/ByteString;
    MethodParameters:
       Name  Flags
      bytes  

  private synchronized boolean send(okio.ByteString, int);
    descriptor: (Lokio/ByteString;I)Z
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // okio.ByteString data
        start local 2 // int formatOpcode
         0: .line 386
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.failed:Z
            ifne 1
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.enqueuedClose:Z
            ifeq 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
         2: .line 389
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.queueSize:J
            aload 1 /* data */
            invokevirtual okio.ByteString.size:()I
            i2l
            ladd
            ldc 16777216
            lcmp
            ifle 5
         3: .line 390
            aload 0 /* this */
            sipush 1001
            aconst_null
            invokevirtual okhttp3.internal.ws.RealWebSocket.close:(ILjava/lang/String;)Z
            pop
         4: .line 391
            iconst_0
            ireturn
         5: .line 395
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            dup
            getfield okhttp3.internal.ws.RealWebSocket.queueSize:J
            aload 1 /* data */
            invokevirtual okio.ByteString.size:()I
            i2l
            ladd
            putfield okhttp3.internal.ws.RealWebSocket.queueSize:J
         6: .line 396
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.messageAndCloseQueue:Ljava/util/ArrayDeque;
            new okhttp3.internal.ws.RealWebSocket$Message
            dup
            iload 2 /* formatOpcode */
            aload 1 /* data */
            invokespecial okhttp3.internal.ws.RealWebSocket$Message.<init>:(ILokio/ByteString;)V
            invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
            pop
         7: .line 397
            aload 0 /* this */
            invokevirtual okhttp3.internal.ws.RealWebSocket.runWriter:()V
         8: .line 398
            iconst_1
            ireturn
        end local 2 // int formatOpcode
        end local 1 // okio.ByteString data
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    9     0          this  Lokhttp3/internal/ws/RealWebSocket;
            0    9     1          data  Lokio/ByteString;
            0    9     2  formatOpcode  I
    MethodParameters:
              Name  Flags
      data          
      formatOpcode  

  synchronized boolean pong(okio.ByteString);
    descriptor: (Lokio/ByteString;)Z
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // okio.ByteString payload
         0: .line 403
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.failed:Z
            ifne 1
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.enqueuedClose:Z
            ifeq 2
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.messageAndCloseQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.isEmpty:()Z
            ifeq 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
         2: .line 405
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.pongQueue:Ljava/util/ArrayDeque;
            aload 1 /* payload */
            invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
            pop
         3: .line 406
            aload 0 /* this */
            invokevirtual okhttp3.internal.ws.RealWebSocket.runWriter:()V
         4: .line 407
            iconst_1
            ireturn
        end local 1 // okio.ByteString payload
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     0     this  Lokhttp3/internal/ws/RealWebSocket;
            0    5     1  payload  Lokio/ByteString;
    MethodParameters:
         Name  Flags
      payload  

  public boolean close(int, java.lang.String);
    descriptor: (ILjava/lang/String;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // int code
        start local 2 // java.lang.String reason
         0: .line 411
            aload 0 /* this */
            iload 1 /* code */
            aload 2 /* reason */
            ldc 60000
            invokevirtual okhttp3.internal.ws.RealWebSocket.close:(ILjava/lang/String;J)Z
            ireturn
        end local 2 // java.lang.String reason
        end local 1 // int code
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0    this  Lokhttp3/internal/ws/RealWebSocket;
            0    1     1    code  I
            0    1     2  reason  Ljava/lang/String;
    MethodParameters:
        Name  Flags
      code    
      reason  

  synchronized boolean close(int, java.lang.String, long);
    descriptor: (ILjava/lang/String;J)Z
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=7, locals=6, args_size=4
        start local 0 // okhttp3.internal.ws.RealWebSocket this
        start local 1 // int code
        start local 2 // java.lang.String reason
        start local 3 // long cancelAfterCloseMillis
         0: .line 415
            iload 1 /* code */
            invokestatic okhttp3.internal.ws.WebSocketProtocol.validateCloseCode:(I)V
         1: .line 417
            aconst_null
            astore 5 /* reasonBytes */
        start local 5 // okio.ByteString reasonBytes
         2: .line 418
            aload 2 /* reason */
            ifnull 6
         3: .line 419
            aload 2 /* reason */
            invokestatic okio.ByteString.encodeUtf8:(Ljava/lang/String;)Lokio/ByteString;
            astore 5 /* reasonBytes */
         4: .line 420
            aload 5 /* reasonBytes */
            invokevirtual okio.ByteString.size:()I
            i2l
            ldc 123
            lcmp
            ifle 6
         5: .line 421
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "reason.size() > 123: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* reason */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 425
      StackMap locals: okio.ByteString
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.failed:Z
            ifne 7
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.enqueuedClose:Z
            ifeq 8
      StackMap locals:
      StackMap stack:
         7: iconst_0
            ireturn
         8: .line 428
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield okhttp3.internal.ws.RealWebSocket.enqueuedClose:Z
         9: .line 431
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.messageAndCloseQueue:Ljava/util/ArrayDeque;
            new okhttp3.internal.ws.RealWebSocket$Close
            dup
            iload 1 /* code */
            aload 5 /* reasonBytes */
            lload 3 /* cancelAfterCloseMillis */
            invokespecial okhttp3.internal.ws.RealWebSocket$Close.<init>:(ILokio/ByteString;J)V
            invokevirtual java.util.ArrayDeque.add:(Ljava/lang/Object;)Z
            pop
        10: .line 432
            aload 0 /* this */
            invokevirtual okhttp3.internal.ws.RealWebSocket.runWriter:()V
        11: .line 433
            iconst_1
            ireturn
        end local 5 // okio.ByteString reasonBytes
        end local 3 // long cancelAfterCloseMillis
        end local 2 // java.lang.String reason
        end local 1 // int code
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot                    Name  Signature
            0   12     0                    this  Lokhttp3/internal/ws/RealWebSocket;
            0   12     1                    code  I
            0   12     2                  reason  Ljava/lang/String;
            0   12     3  cancelAfterCloseMillis  J
            2   12     5             reasonBytes  Lokio/ByteString;
    MethodParameters:
                        Name  Flags
      code                    
      reason                  
      cancelAfterCloseMillis  

  private void runWriter();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 437
            getstatic okhttp3.internal.ws.RealWebSocket.$assertionsDisabled:Z
            ifne 1
            aload 0 /* this */
            invokestatic java.lang.Thread.holdsLock:(Ljava/lang/Object;)Z
            ifne 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 439
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.executor:Ljava/util/concurrent/ScheduledExecutorService;
            ifnull 3
         2: .line 440
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.executor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.writerRunnable:Ljava/lang/Runnable;
            invokeinterface java.util.concurrent.ScheduledExecutorService.execute:(Ljava/lang/Runnable;)V
         3: .line 442
      StackMap locals:
      StackMap stack:
            return
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lokhttp3/internal/ws/RealWebSocket;

  boolean writeOneFrame();
    descriptor: ()Z
    flags: (0x0000) 
    Code:
      stack=6, locals=11, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 460
            aconst_null
            astore 3 /* messageOrClose */
        start local 3 // java.lang.Object messageOrClose
         1: .line 461
            iconst_m1
            istore 4 /* receivedCloseCode */
        start local 4 // int receivedCloseCode
         2: .line 462
            aconst_null
            astore 5 /* receivedCloseReason */
        start local 5 // java.lang.String receivedCloseReason
         3: .line 463
            aconst_null
            astore 6 /* streamsToClose */
        start local 6 // okhttp3.internal.ws.RealWebSocket$Streams streamsToClose
         4: .line 465
            aload 0 /* this */
            dup
            astore 7
            monitorenter
         5: .line 466
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.failed:Z
            ifeq 8
         6: .line 467
            aload 7
            monitorexit
         7: iconst_0
            ireturn
         8: .line 470
      StackMap locals: okhttp3.internal.ws.RealWebSocket top top java.lang.Object int java.lang.String okhttp3.internal.ws.RealWebSocket$Streams okhttp3.internal.ws.RealWebSocket
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.writer:Lokhttp3/internal/ws/WebSocketWriter;
            astore 1 /* writer */
        start local 1 // okhttp3.internal.ws.WebSocketWriter writer
         9: .line 471
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.pongQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.poll:()Ljava/lang/Object;
            checkcast okio.ByteString
            astore 2 /* pong */
        start local 2 // okio.ByteString pong
        10: .line 472
            aload 2 /* pong */
            ifnonnull 27
        11: .line 473
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.messageAndCloseQueue:Ljava/util/ArrayDeque;
            invokevirtual java.util.ArrayDeque.poll:()Ljava/lang/Object;
            astore 3 /* messageOrClose */
        12: .line 474
            aload 3 /* messageOrClose */
            instanceof okhttp3.internal.ws.RealWebSocket$Close
            ifeq 24
        13: .line 475
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.receivedCloseCode:I
            istore 4 /* receivedCloseCode */
        14: .line 476
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.receivedCloseReason:Ljava/lang/String;
            astore 5 /* receivedCloseReason */
        15: .line 477
            iload 4 /* receivedCloseCode */
            iconst_m1
            if_icmpeq 20
        16: .line 478
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.streams:Lokhttp3/internal/ws/RealWebSocket$Streams;
            astore 6 /* streamsToClose */
        17: .line 479
            aload 0 /* this */
            aconst_null
            putfield okhttp3.internal.ws.RealWebSocket.streams:Lokhttp3/internal/ws/RealWebSocket$Streams;
        18: .line 480
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.executor:Ljava/util/concurrent/ScheduledExecutorService;
            invokeinterface java.util.concurrent.ScheduledExecutorService.shutdown:()V
        19: .line 481
            goto 27
        20: .line 483
      StackMap locals: okhttp3.internal.ws.RealWebSocket okhttp3.internal.ws.WebSocketWriter okio.ByteString java.lang.Object int java.lang.String okhttp3.internal.ws.RealWebSocket$Streams okhttp3.internal.ws.RealWebSocket
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.executor:Ljava/util/concurrent/ScheduledExecutorService;
            new okhttp3.internal.ws.RealWebSocket$CancelRunnable
            dup
            aload 0 /* this */
            invokespecial okhttp3.internal.ws.RealWebSocket$CancelRunnable.<init>:(Lokhttp3/internal/ws/RealWebSocket;)V
        21: .line 484
            aload 3 /* messageOrClose */
            checkcast okhttp3.internal.ws.RealWebSocket$Close
            getfield okhttp3.internal.ws.RealWebSocket$Close.cancelAfterCloseMillis:J
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
        22: .line 483
            invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
            putfield okhttp3.internal.ws.RealWebSocket.cancelFuture:Ljava/util/concurrent/ScheduledFuture;
        23: .line 486
            goto 27
      StackMap locals:
      StackMap stack:
        24: aload 3 /* messageOrClose */
            ifnonnull 27
        25: .line 487
            aload 7
            monitorexit
        26: iconst_0
            ireturn
        27: .line 465
      StackMap locals:
      StackMap stack:
            aload 7
            monitorexit
        28: goto 31
        end local 2 // okio.ByteString pong
        end local 1 // okhttp3.internal.ws.WebSocketWriter writer
      StackMap locals: okhttp3.internal.ws.RealWebSocket top top java.lang.Object int java.lang.String okhttp3.internal.ws.RealWebSocket$Streams okhttp3.internal.ws.RealWebSocket
      StackMap stack: java.lang.Throwable
        29: aload 7
            monitorexit
        30: athrow
        start local 1 // okhttp3.internal.ws.WebSocketWriter writer
        start local 2 // okio.ByteString pong
        31: .line 493
      StackMap locals: okhttp3.internal.ws.RealWebSocket okhttp3.internal.ws.WebSocketWriter okio.ByteString java.lang.Object int java.lang.String okhttp3.internal.ws.RealWebSocket$Streams
      StackMap stack:
            aload 2 /* pong */
            ifnull 34
        32: .line 494
            aload 1 /* writer */
            aload 2 /* pong */
            invokevirtual okhttp3.internal.ws.WebSocketWriter.writePong:(Lokio/ByteString;)V
        33: .line 496
            goto 54
      StackMap locals:
      StackMap stack:
        34: aload 3 /* messageOrClose */
            instanceof okhttp3.internal.ws.RealWebSocket$Message
            ifeq 47
        35: .line 497
            aload 3 /* messageOrClose */
            checkcast okhttp3.internal.ws.RealWebSocket$Message
            getfield okhttp3.internal.ws.RealWebSocket$Message.data:Lokio/ByteString;
            astore 7 /* data */
        start local 7 // okio.ByteString data
        36: .line 498
            aload 1 /* writer */
        37: .line 499
            aload 3 /* messageOrClose */
            checkcast okhttp3.internal.ws.RealWebSocket$Message
            getfield okhttp3.internal.ws.RealWebSocket$Message.formatOpcode:I
            aload 7 /* data */
            invokevirtual okio.ByteString.size:()I
            i2l
        38: .line 498
            invokevirtual okhttp3.internal.ws.WebSocketWriter.newMessageSink:(IJ)Lokio/Sink;
            invokestatic okio.Okio.buffer:(Lokio/Sink;)Lokio/BufferedSink;
            astore 8 /* sink */
        start local 8 // okio.BufferedSink sink
        39: .line 500
            aload 8 /* sink */
            aload 7 /* data */
            invokeinterface okio.BufferedSink.write:(Lokio/ByteString;)Lokio/BufferedSink;
            pop
        40: .line 501
            aload 8 /* sink */
            invokeinterface okio.BufferedSink.close:()V
        41: .line 502
            aload 0 /* this */
            dup
            astore 9
            monitorenter
        42: .line 503
            aload 0 /* this */
            dup
            getfield okhttp3.internal.ws.RealWebSocket.queueSize:J
            aload 7 /* data */
            invokevirtual okio.ByteString.size:()I
            i2l
            lsub
            putfield okhttp3.internal.ws.RealWebSocket.queueSize:J
        43: .line 502
            aload 9
            monitorexit
        44: goto 54
      StackMap locals: okhttp3.internal.ws.RealWebSocket okhttp3.internal.ws.WebSocketWriter okio.ByteString java.lang.Object int java.lang.String okhttp3.internal.ws.RealWebSocket$Streams okio.ByteString okio.BufferedSink okhttp3.internal.ws.RealWebSocket
      StackMap stack: java.lang.Throwable
        45: aload 9
            monitorexit
        46: athrow
        end local 8 // okio.BufferedSink sink
        end local 7 // okio.ByteString data
        47: .line 506
      StackMap locals:
      StackMap stack:
            aload 3 /* messageOrClose */
            instanceof okhttp3.internal.ws.RealWebSocket$Close
            ifeq 53
        48: .line 507
            aload 3 /* messageOrClose */
            checkcast okhttp3.internal.ws.RealWebSocket$Close
            astore 7 /* close */
        start local 7 // okhttp3.internal.ws.RealWebSocket$Close close
        49: .line 508
            aload 1 /* writer */
            aload 7 /* close */
            getfield okhttp3.internal.ws.RealWebSocket$Close.code:I
            aload 7 /* close */
            getfield okhttp3.internal.ws.RealWebSocket$Close.reason:Lokio/ByteString;
            invokevirtual okhttp3.internal.ws.WebSocketWriter.writeClose:(ILokio/ByteString;)V
        50: .line 511
            aload 6 /* streamsToClose */
            ifnull 54
        51: .line 512
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.listener:Lokhttp3/WebSocketListener;
            aload 0 /* this */
            iload 4 /* receivedCloseCode */
            aload 5 /* receivedCloseReason */
            invokevirtual okhttp3.WebSocketListener.onClosed:(Lokhttp3/WebSocket;ILjava/lang/String;)V
        end local 7 // okhttp3.internal.ws.RealWebSocket$Close close
        52: .line 515
            goto 54
        53: .line 516
      StackMap locals:
      StackMap stack:
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        54: .line 521
      StackMap locals:
      StackMap stack:
            aload 6 /* streamsToClose */
            invokestatic okhttp3.internal.Util.closeQuietly:(Ljava/io/Closeable;)V
        55: .line 519
            iconst_1
            ireturn
        56: .line 520
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 10
        57: .line 521
            aload 6 /* streamsToClose */
            invokestatic okhttp3.internal.Util.closeQuietly:(Ljava/io/Closeable;)V
        58: .line 522
            aload 10
            athrow
        end local 6 // okhttp3.internal.ws.RealWebSocket$Streams streamsToClose
        end local 5 // java.lang.String receivedCloseReason
        end local 4 // int receivedCloseCode
        end local 3 // java.lang.Object messageOrClose
        end local 2 // okio.ByteString pong
        end local 1 // okhttp3.internal.ws.WebSocketWriter writer
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0   59     0                 this  Lokhttp3/internal/ws/RealWebSocket;
            9   29     1               writer  Lokhttp3/internal/ws/WebSocketWriter;
           31   59     1               writer  Lokhttp3/internal/ws/WebSocketWriter;
           10   29     2                 pong  Lokio/ByteString;
           31   59     2                 pong  Lokio/ByteString;
            1   59     3       messageOrClose  Ljava/lang/Object;
            2   59     4    receivedCloseCode  I
            3   59     5  receivedCloseReason  Ljava/lang/String;
            4   59     6       streamsToClose  Lokhttp3/internal/ws/RealWebSocket$Streams;
           36   47     7                 data  Lokio/ByteString;
           39   47     8                 sink  Lokio/BufferedSink;
           49   52     7                close  Lokhttp3/internal/ws/RealWebSocket$Close;
      Exception table:
        from    to  target  type
           5     7      29  any
           8    26      29  any
          27    28      29  any
          29    30      29  any
          42    44      45  any
          45    46      45  any
          31    54      56  any
    Exceptions:
      throws java.io.IOException

  void writePingFrame();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=6, locals=4, args_size=1
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 537
            aload 0 /* this */
            dup
            astore 3
            monitorenter
         1: .line 538
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.failed:Z
            ifeq 3
            aload 3
            monitorexit
         2: return
         3: .line 539
      StackMap locals: okhttp3.internal.ws.RealWebSocket top top okhttp3.internal.ws.RealWebSocket
      StackMap stack:
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.writer:Lokhttp3/internal/ws/WebSocketWriter;
            astore 1 /* writer */
        start local 1 // okhttp3.internal.ws.WebSocketWriter writer
         4: .line 540
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.awaitingPong:Z
            ifeq 5
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.sentPingCount:I
            goto 6
      StackMap locals: okhttp3.internal.ws.RealWebSocket okhttp3.internal.ws.WebSocketWriter top okhttp3.internal.ws.RealWebSocket
      StackMap stack:
         5: iconst_m1
      StackMap locals:
      StackMap stack: int
         6: istore 2 /* failedPing */
        start local 2 // int failedPing
         7: .line 541
            aload 0 /* this */
            dup
            getfield okhttp3.internal.ws.RealWebSocket.sentPingCount:I
            iconst_1
            iadd
            putfield okhttp3.internal.ws.RealWebSocket.sentPingCount:I
         8: .line 542
            aload 0 /* this */
            iconst_1
            putfield okhttp3.internal.ws.RealWebSocket.awaitingPong:Z
         9: .line 537
            aload 3
            monitorexit
        10: goto 13
        end local 2 // int failedPing
        end local 1 // okhttp3.internal.ws.WebSocketWriter writer
      StackMap locals: okhttp3.internal.ws.RealWebSocket top top okhttp3.internal.ws.RealWebSocket
      StackMap stack: java.lang.Throwable
        11: aload 3
            monitorexit
        12: athrow
        start local 1 // okhttp3.internal.ws.WebSocketWriter writer
        start local 2 // int failedPing
        13: .line 545
      StackMap locals: okhttp3.internal.ws.RealWebSocket okhttp3.internal.ws.WebSocketWriter int
      StackMap stack:
            iload 2 /* failedPing */
            iconst_m1
            if_icmpeq 19
        14: .line 546
            aload 0 /* this */
            new java.net.SocketTimeoutException
            dup
            new java.lang.StringBuilder
            dup
            ldc "sent ping but didn't receive pong within "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
        15: .line 547
            aload 0 /* this */
            getfield okhttp3.internal.ws.RealWebSocket.pingIntervalMillis:J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            ldc "ms (after "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            iload 2 /* failedPing */
            iconst_1
            isub
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " successful ping/pongs)"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.net.SocketTimeoutException.<init>:(Ljava/lang/String;)V
        16: .line 548
            aconst_null
        17: .line 546
            invokevirtual okhttp3.internal.ws.RealWebSocket.failWebSocket:(Ljava/lang/Exception;Lokhttp3/Response;)V
        18: .line 549
            return
        19: .line 553
      StackMap locals:
      StackMap stack:
            aload 1 /* writer */
            getstatic okio.ByteString.EMPTY:Lokio/ByteString;
            invokevirtual okhttp3.internal.ws.WebSocketWriter.writePing:(Lokio/ByteString;)V
        20: .line 554
            goto 23
      StackMap locals:
      StackMap stack: java.io.IOException
        21: astore 3 /* e */
        start local 3 // java.io.IOException e
        22: .line 555
            aload 0 /* this */
            aload 3 /* e */
            aconst_null
            invokevirtual okhttp3.internal.ws.RealWebSocket.failWebSocket:(Ljava/lang/Exception;Lokhttp3/Response;)V
        end local 3 // java.io.IOException e
        23: .line 557
      StackMap locals:
      StackMap stack:
            return
        end local 2 // int failedPing
        end local 1 // okhttp3.internal.ws.WebSocketWriter writer
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   24     0        this  Lokhttp3/internal/ws/RealWebSocket;
            4   11     1      writer  Lokhttp3/internal/ws/WebSocketWriter;
           13   24     1      writer  Lokhttp3/internal/ws/WebSocketWriter;
            7   11     2  failedPing  I
           13   24     2  failedPing  I
           22   23     3           e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           1     2      11  any
           3    10      11  any
          11    12      11  any
          19    20      21  Class java.io.IOException

  public void failWebSocket(java.lang.Exception, okhttp3.Response);
    descriptor: (Ljava/lang/Exception;Lokhttp3/Response;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // okhttp3.internal.ws.RealWebSocket this
         0: .line 559
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tNullable cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // okhttp3.internal.ws.RealWebSocket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lokhttp3/internal/ws/RealWebSocket;
    RuntimeInvisibleTypeAnnotations: 
      METHOD_FORMAL_PARAMETER
        Nullable()
    RuntimeInvisibleParameterAnnotations: 
      0:
      1:
        Nullable()
    MethodParameters:
          Name  Flags
      e         
      response  
}
SourceFile: "RealWebSocket.java"
NestMembers:
  okhttp3.internal.ws.RealWebSocket$1  okhttp3.internal.ws.RealWebSocket$2  okhttp3.internal.ws.RealWebSocket$CancelRunnable  okhttp3.internal.ws.RealWebSocket$Close  okhttp3.internal.ws.RealWebSocket$Message  okhttp3.internal.ws.RealWebSocket$PingRunnable  okhttp3.internal.ws.RealWebSocket$Streams
InnerClasses:
  public final Builder = okhttp3.OkHttpClient$Builder of okhttp3.OkHttpClient
  public Builder = okhttp3.Request$Builder of okhttp3.Request
  okhttp3.internal.ws.RealWebSocket$1
  okhttp3.internal.ws.RealWebSocket$2
  final CancelRunnable = okhttp3.internal.ws.RealWebSocket$CancelRunnable of okhttp3.internal.ws.RealWebSocket
  final Close = okhttp3.internal.ws.RealWebSocket$Close of okhttp3.internal.ws.RealWebSocket
  final Message = okhttp3.internal.ws.RealWebSocket$Message of okhttp3.internal.ws.RealWebSocket
  private final PingRunnable = okhttp3.internal.ws.RealWebSocket$PingRunnable of okhttp3.internal.ws.RealWebSocket
  public abstract Streams = okhttp3.internal.ws.RealWebSocket$Streams of okhttp3.internal.ws.RealWebSocket
  public abstract FrameCallback = okhttp3.internal.ws.WebSocketReader$FrameCallback of okhttp3.internal.ws.WebSocketReader