try {
            while (scrollId != null) {
                final SearchHits searchHits = response.getHits();
                if (searchHits.getHits().length == 0) {
                    break;
                }

                for (final SearchHit searchHit : searchHits) {
                    final Map<String, Object> source = searchHit.getSourceAsMap();

/**
 * Tests for {@link PercentEscaper}.
 *
 * @author David Beaumont
 */
@GwtCompatible
@NullUnmarked
public class PercentEscaperTest extends TestCase {

  /** Tests that the simple escaper treats 0-9, a-z and A-Z as safe */
  public void testSimpleEscaper() {
    UnicodeEscaper e = new PercentEscaper("", false);
    for (char c = 0; c < 128; c++) {

            assertNotNull(jobProcess);

            // Poll for process to complete
            for (int i = 0; i < 50; i++) {
                if (!jobProcess.getProcess().isAlive()) {
                    break;
                }
                Thread.sleep(100);
            }

            // Clean up
            processHelper.destroyProcess(sessionId);
        } catch (Exception e) {

	if err != nil {
		t.Fatal(err)
	}

	for {
		_, err := restClient.DiskInfo(t.Context(), DiskInfoOptions{})
		if err == nil || errors.Is(err, errUnformattedDisk) {
			break
		}
		time.Sleep(time.Duration(rand.Float64() * float64(100*time.Millisecond)))
	}

	return restClient
}

func TestStorageRESTClientDiskInfo(t *testing.T) {

    assertThat(at.doubleValue()).isEqualTo(0.0d);
    for (double x : VALUES) {
      at.set(x);
      assertBitEquals(x, at.doubleValue());
    }
  }

  /** compareAndSet treats +0.0 and -0.0 as distinct values */
  public void testDistinctZeros() {
    AtomicDouble at = new AtomicDouble(+0.0);
    assertFalse(at.compareAndSet(-0.0, 7.0));
    assertFalse(at.weakCompareAndSet(-0.0, 7.0));

                }

                if (!ComponentUtil.available()) {
                    logger.info("IndexUpdater is terminated.");
                    forceStop();
                    break;
                }
            }

            if (logger.isDebugEnabled()) {
                logger.debug("Finished indexUpdater.");
            }
        } catch (final ContainerNotAvailableException e) {

			retry := time.Duration(r.Float64() * float64(5*time.Second))
			storageLogIf(ctx, fmt.Errorf("Unable to initialize backend: %w, retrying in %s", err, retry))
			time.Sleep(retry)
			attempt++
			continue
		}
		break
	}

	// initialize the incomplete uploads cache
	z.mpCache = xsync.NewMapOf[string, MultipartInfo]()

	go z.cleanupStaleMPCache(ctx)

	return z, nil
}

                case 2:
                    segmentation = values[1];
                case 1:
                    token = values[0];
                default:
                    break;
                }

                id++;
                final KuromojiItem item = new KuromojiItem(id, token, segmentation, reading, pos);
                if (updater != null) {

                section.html(inSectionElements.outerHtml());
                inSectionElements.remove();

                if (next == null) {
                    break;
                } else {
                    inSection.clear();
                    inSection.add(next);
                    heading = next;
                }
            } else {

        // too short to sleep
        Thread.yield();
      }
      long d = ns - (System.nanoTime() - startTime);
      if (d > 0L) {
        millis = d / (1000 * 1000);
      } else {
        break;
      }
    }
  }

  /** Waits out termination of a thread pool or fails doing so. */
  final void joinPool(ExecutorService exec) throws InterruptedException {
    try {
      exec.shutdown();