testEncodeChunkedContentV2() — netty Function Reference

Source Code

codec-http/src/test/java/io/netty/handler/codec/http/multipart/HttpPostRequestEncoderTest.java lines 479–511

    @Test
    public void testEncodeChunkedContentV2() throws Exception {
        final Map<String, String> params = new LinkedHashMap<String, String>();
        params.put("data", largeText("data", 3));
        params.put("empty", "");
        params.put("tiny", "a");
        params.put("large", generateString(chunkSize - 7 - 7 - 1 - 8));
        params.put("huge", largeText("huge", 8));
        params.put("small", "abcd");

        final StringBuilder expectQueryStr = new StringBuilder();
        final HttpRequest req = new DefaultHttpRequest(HTTP_1_1, POST, "/");
        final HttpPostRequestEncoder encoder = new HttpPostRequestEncoder(req, false);
        for (Entry<String, String> entry : params.entrySet()) {
            final String key = entry.getKey();
            final String value = entry.getValue();
            encoder.addBodyAttribute(key, value);
            expectQueryStr.append(key).append('=').append(value).append('&');
        }
        expectQueryStr.setLength(expectQueryStr.length() - 1); //remove last '&'
        assertNotNull(encoder.finalizeRequest());

        final StringBuilder chunks = new StringBuilder();
        while (!encoder.isEndOfInput()) {
            final HttpContent httpContent = encoder.readChunk((ByteBufAllocator) null);
            chunks.append(httpContent.content().toString(UTF_8));
            httpContent.release();
        }

        assertTrue(encoder.isEndOfInput());
        assertEquals(expectQueryStr.toString(), chunks.toString());
        encoder.cleanFiles();
    }