val promisedStreamId = source.readInt() and 0x7fffffff
    val headerBlockLength = lengthWithoutPadding(length - 4, flags, padding) // - 4 for readInt().
    val headerBlock = readHeaderBlock(headerBlockLength, padding, flags, streamId)
    handler.pushPromise(streamId, promisedStreamId, headerBlock)
  }

  @Throws(IOException::class)
  private fun readPing(
    handler: Handler,
    length: Int,

    protected void setUp() throws Exception {
        file1 = File.createTempFile("kuromoji_", ".txt");
        FileUtil.write(
                file1.getAbsolutePath(),
                "token1,seg1,reading1,pos1\ntoken2,seg2,reading2,pos2\ntoken3,seg3,reading3,pos3"
                        .getBytes(Constants.UTF_8));
    }

    @Override
        protected void tearDown(TestInfo testInfo) throws Exception {
        file1.delete();
    }

    // Tests for reading arrays edge cases
    // ============================================================

    @Test
    public void test_manyReadingsForOneWord() {
        String[] text = { "test" };
        String[][] readings = { { "reading1", "reading2", "reading3", "reading4", "reading5", "reading6", "reading7", "reading8",
                "reading9", "reading10" } };

    }

    @Test
    public void testToJson() {
        String[] text = { "json test" };
        String[][] readings = { { "reading" } };
        String[] fields = { "field" };

        SuggestItem item = new SuggestItem(text, readings, fields, 1L, 1L, 1.0f, new String[0], new String[0], new String[0],
                SuggestItem.Kind.DOCUMENT);

                if (readings != null && readings.length > i && readings[i].length > 0) {
                    for (final String reading : readings[i]) {
                        if (!l.contains(reading)) {
                            l.add(reading);
                        }
                    }
                }

                wordsList.add(word);

  }

  /**
   * Opens a new {@link Stream} for reading text one line at a time from this source. This method
   * returns a new, independent stream each time it is called.
   *
   * <p>The returned stream is lazy and only reads from the source in the terminal operation. If an
   * I/O error occurs while the stream is reading from the source or when the stream is closed, an
   * {@link UncheckedIOException} is thrown.

            final boolean apply) {
        final String[] readings;
        if (StringUtil.isBlank(reading)) {
            readings = word.replace("　", TEXT_SEP).replaceAll(TEXT_SEP + "+", TEXT_SEP).split(TEXT_SEP);
        } else {
            readings = reading.replace("　", TEXT_SEP).replaceAll(TEXT_SEP + "+", TEXT_SEP).split(TEXT_SEP);
        }

        final List<String> labelList = new ArrayList<>();
        if (tags != null) {

        assertNotNull(result);

        String queryString = result.toString();
        // Should have both readings
        assertTrue("Should contain original text", queryString.contains("test"));
        assertTrue("Should contain converted reading", queryString.contains("test_reading"));
    }

    @Test
    public void test_buildQuery_threeWords() {

Brad Fitzpatrick <******@****.***> 1764180701 -0800

Carlos Amedee <******@****.***> 1769025172 -0500