app = FastAPI()


class CommonHeaders(BaseModel):
    host: str
    save_data: bool
    if_modified_since: str | None = None
    traceparent: str | None = None
    x_tag: list[str] = []


@app.get("/items/")
async def read_items(
    headers: Annotated[CommonHeaders, Header(convert_underscores=False)],
):

    Iterator<String> iterator = list.iterator();
    assertEquals("b", get(iterator, 1));
    assertFalse(iterator.hasNext());
  }

  public void testGet_atSize() {
    List<String> list = new ArrayList<>();
    list.add("a");
    list.add("b");
    Iterator<String> iterator = list.iterator();
    assertThrows(IndexOutOfBoundsException.class, () -> get(iterator, 2));
    assertFalse(iterator.hasNext());
  }

        int matchCount = 0;
        for (int i = 0; i < tokens.size(); i++) {
            final String term = tokens.get(i).getTerm();
            final String reading = readingTokens.get(i).getTerm();
            switch (term) {
            case "fess":
                matchCount++;
                assertEquals("fess", reading);
                break;

            }
        }
    }

    /**
     * Get the AP options flags.
     *
     * @return the AP options byte
     */
    public byte getApOptions() {
        return this.apOptions;
    }

    /**
     * Get the Kerberos ticket from this AP request.
     *
     * @return the Kerberos ticket
     */

      assertTrue(Thread.holdsLock(mutex));
      return delegate.containsRow(rowKey);
    }

    @Override
    public @Nullable V get(Object rowKey, Object columnKey) {
      assertTrue(Thread.holdsLock(mutex));
      return delegate.get(rowKey, columnKey);
    }

    @Override
    public @Nullable V put(R rowKey, C columnKey, V value) {
      assertTrue(Thread.holdsLock(mutex));

     */
    int PIPE_TYPE_DCE_TRANSACT = 0x0200 | 0x0400;

    /**
     * Pipe should use it's own exclusive transport connection
     */
    int PIPE_TYPE_UNSHARED = 0x800;

    /**
     * Gets the type of this pipe.
     *
     * @return the type of the pipe
     */
    int getPipeType();

    /**
     * Create a pipe handle
     *
     * @return pipe handle, needs to be closed when finished

     * @param rootCause the cause of this exception
     */
    public TransportException(final String msg, final Throwable rootCause) {
        super(msg, rootCause);
    }

    /**
     * Gets the root cause of this exception.
     * @return root cause of this exception
     */
    @Deprecated
    public Throwable getRootCause() {
        return getCause();
    }

     *
     * @param targetName the target name string to encode
     */
    public AvTargetName(final String targetName) {
        this(encode(targetName));
    }

    /**
     * Gets the target name from this AV pair
     *
     * @return the target name
     */
    public String getTargetName() {
        return new String(getRaw(), UTF16LE);
    }

    /**
     * @param targetName

import okhttp3.Call;
import okhttp3.HttpUrl;

import java.io.IOException;

public class Main {
  public static void main(String[] args) throws IOException {
    Call call = OkHttpCaller.callOkHttp(HttpUrl.get("https://square.com/robots.txt"));

    System.out.println(call.execute().body().string());
  }

import okio.BufferedSource
import okio.Source
import okio.source
import org.brotli.dec.BrotliInputStream

object Brotli : CompressionInterceptor.DecompressionAlgorithm {
  override val encoding: String get() = "br"

  override fun decompress(compressedSource: BufferedSource): Source = BrotliInputStream(compressedSource.inputStream()).source()