private val headersQueue = ArrayDeque<Headers>()

  /** True if response headers have been sent or received. */
  private var hasResponseHeaders: Boolean = false

  override val source =
    FramingSource(
      maxByteCount = connection.okHttpSettings.initialWindowSize.toLong(),
      finished = inFinished,
    )
  override val sink =
    FramingSink(
      finished = outFinished,
    )

HSPLokhttp3/internal/http2/Http2Stream$FramingSink;->write(Lokio/Buffer;J)V
HSPLokhttp3/internal/http2/Http2Stream$FramingSource;-><init>(Lokhttp3/internal/http2/Http2Stream;JZ)V
HSPLokhttp3/internal/http2/Http2Stream$FramingSource;->close()V
HSPLokhttp3/internal/http2/Http2Stream$FramingSource;->read(Lokio/Buffer;J)J
HSPLokhttp3/internal/http2/Http2Stream$FramingSource;->updateConnectionFlowControl(J)V