larksuite-oapi/src/main/java/com/larksuite/oapi/okhttp3_14/internal/http2/Http2Stream.java
void receiveHeaders(Headers headers, boolean inFinished) {
    assert (!Thread.holdsLock(Http2Stream.this));
    boolean open;
    synchronized (this) {
      if (!hasResponseHeaders || !inFinished) {
        hasResponseHeaders = true;
        headersQueue.add(headers);
      } else {
        this.source.trailers = headers;
      }
      if (inFinished) {
        this.source.finished = true;
      }
      open = isOpen();
      notifyAll();
    }
    if (!open) {
      connection.removeStream(id);
    }
  }
/**
   * Accept headers from the network and store them until the client calls {@link #takeHeaders}, or
   * {@link FramingSource#read} them.
   */
Accept headers from the network and store them until the client calls  #takeHeaders, or
FramingSource#read them.
Accept headers from the network and store them until the client calls #takeHeaders or FramingSource#read them .
void receiveHeaders(Headers headers, boolean inFinished) {
    assert (!Thread.holdsLock(Http2Stream.this));
    boolean open;
    synchronized (this) {
      if (!hasResponseHeaders || !inFinished) {
        hasResponseHeaders = true;
        headersQueue.add(headers);
      } else {
        this.source.trailers = headers;
      }
      if (inFinished) {
        this.source.finished = true;
      }
      open = isOpen();
      notifyAll();
    }
    if (!open) {
      connection.removeStream(id);
    }
  }
void receiveHeaders ( Headers headers , boolean inFinished ) { assert ( ! Thread . holdsLock ( Http2Stream . this ) ) ; boolean open ; synchronized ( this ) { if ( ! hasResponseHeaders || ! inFinished ) { hasResponseHeaders = true ; headersQueue . add ( headers ) ; } else { this . source . trailers = headers ; } if ( inFinished ) { this . source . finished = true ; } open = isOpen ( ) ; notifyAll ( ) ; } if ( ! open ) { connection . removeStream ( id ) ; } }
Accept headers from the network and store them until the client calls {@link #takeHeaders}, or
 {@link FramingSource#read} them.
Accept headers from the network and store them until the client calls { @link #takeHeaders } or { @link FramingSource#read } them .