AQ,IAC3C+yB,mBAA6B,MAATl6B,EAAgB,GAAKA,IAG5C,GAAU,MAALiC,EACJ,MAAO,GAIR,GAAKxD,MAAMC,QAASuD,IAASA,EAAE5F,SAAWR,EAAO2C,cAAeyD,GAG/DpG,EAAOkB,KAAMkF,EAAG,WACfuS,EAAK3b,KAAKqF,KAAMrF,KAAKmH,cAOtB,IAAMgxB,KAAU/uB,EACf43B,GAAa7I,EAAQ/uB,EAAG+uB,GAAU8I,EAAatlB,GAKjD,OAAOwlB,EAAEtzB,KAAM,MAGhB7K,EAAOG,GAAGgC,OAAQ,CACjBm8B,UAAW,WACV,OAAOt+B,EAAOk+B,MAAOlhC,KAAKuhC,mBAE3BA,eAAgB,WACf,OAAOvhC,KAAKoE,IAAK,WAGhB,IAAI6N,EAAWjP,EAAO6f,KAAM7iB,KAAM,YAClC,OAAOiS,EAAWjP,EAAO2D,UAAWsL,GAAajS,OAC9CyQ,OAAQ,WACX,IAA...

AQ,IAC3C+yB,mBAA6B,MAATl6B,EAAgB,GAAKA,IAG5C,GAAU,MAALiC,EACJ,MAAO,GAIR,GAAKxD,MAAMC,QAASuD,IAASA,EAAE5F,SAAWR,EAAO2C,cAAeyD,GAG/DpG,EAAOkB,KAAMkF,EAAG,WACfuS,EAAK3b,KAAKqF,KAAMrF,KAAKmH,cAOtB,IAAMgxB,KAAU/uB,EACf43B,GAAa7I,EAAQ/uB,EAAG+uB,GAAU8I,EAAatlB,GAKjD,OAAOwlB,EAAEtzB,KAAM,MAGhB7K,EAAOG,GAAGgC,OAAQ,CACjBm8B,UAAW,WACV,OAAOt+B,EAAOk+B,MAAOlhC,KAAKuhC,mBAE3BA,eAAgB,WACf,OAAOvhC,KAAKoE,IAAK,WAGhB,IAAI6N,EAAWjP,EAAO6f,KAAM7iB,KAAM,YAClC,OAAOiS,EAAWjP,EAAO2D,UAAWsL,GAAajS,OAC9CyQ,OAAQ,WACX,IAA...

    MIN(Long.MIN_VALUE, "-oo"),
    MINUS_SMALL(-SMALL_TIMEOUT_MILLIS, "-" + SMALL_TIMEOUT_MILLIS + "ms"),
    ZERO(0L, "0ms"),
    SMALL(SMALL_TIMEOUT_MILLIS, SMALL_TIMEOUT_MILLIS + "ms"),
    LARGE(UNEXPECTED_HANG_DELAY_MILLIS * 2, (2 * UNEXPECTED_HANG_DELAY_MILLIS) + "ms"),
    MAX(Long.MAX_VALUE, "+oo");

    final long millis;
    final String label;

    Timeout(long millis, String label) {
      this.millis = millis;

    public static void sleep(final long millis) {
        if (millis < 1L) {
            return;
        }
        try {
            Thread.sleep(millis);
        } catch (final InterruptedException e) {
            throw new InterruptedRuntimeException(e);
        }
    }

    public static void sleepQuietly(final long millis) {
        if (millis < 1L) {
            return;
        }
        try {

    MIN(Long.MIN_VALUE, "-oo"),
    MINUS_SMALL(-SMALL_TIMEOUT_MILLIS, "-" + SMALL_TIMEOUT_MILLIS + "ms"),
    ZERO(0L, "0ms"),
    SMALL(SMALL_TIMEOUT_MILLIS, SMALL_TIMEOUT_MILLIS + "ms"),
    LARGE(UNEXPECTED_HANG_DELAY_MILLIS * 2, (2 * UNEXPECTED_HANG_DELAY_MILLIS) + "ms"),
    MAX(Long.MAX_VALUE, "+oo");

    final long millis;
    final String label;

    Timeout(long millis, String label) {
      this.millis = millis;

  }

  private static class SleepingRunnable implements Runnable {
    final int millis;
    volatile boolean completed;

    public SleepingRunnable(int millis) {
      this.millis = millis;
    }

    @Override
    public void run() {
      try {
        Thread.sleep(millis);
      } catch (InterruptedException wontHappen) {
        throw new AssertionError();
      }

 * @author Justin T. Sampson
 */
public final class TestThread<L> extends Thread implements TearDown {

  private static final long DUE_DILIGENCE_MILLIS = 100;
  private static final long TIMEOUT_MILLIS = 5000;

  private final L lockLikeObject;

  private final SynchronousQueue<Request> requestQueue = new SynchronousQueue<>();

        }
        val sendRequestMillisString = responseHeadersBuilder[SENT_MILLIS]
        val receivedResponseMillisString = responseHeadersBuilder[RECEIVED_MILLIS]
        responseHeadersBuilder.removeAll(SENT_MILLIS)
        responseHeadersBuilder.removeAll(RECEIVED_MILLIS)
        sentRequestMillis = sendRequestMillisString?.toLong() ?: 0L

  }

  private static class SleepingRunnable implements Runnable {
    final int millis;
    volatile boolean completed;

    public SleepingRunnable(int millis) {
      this.millis = millis;
    }

    @Override
    public void run() {
      try {
        Thread.sleep(millis);
      } catch (InterruptedException wontHappen) {
        throw new AssertionError();
      }

 * @author Justin T. Sampson
 */
public final class TestThread<L> extends Thread implements TearDown {

  private static final long DUE_DILIGENCE_MILLIS = 100;
  private static final long TIMEOUT_MILLIS = 5000;

  private final L lockLikeObject;

  private final SynchronousQueue<Request> requestQueue = new SynchronousQueue<>();