Method putStreamBody

Tests/Libraries/Http/HttpAsyncClientTest.cpp:957–1041

    {
        SC_TEST_EXPECT(threadPool.create(2));
    }
    SC_TEST_EXPECT(httpServer.init(Span<ServerConnection>(connections)));
    SC_TEST_EXPECT(httpServer.start(loop, "127.0.0.1", port));
    SC_TEST_EXPECT(fileServer.init(threadPool, loop, webServerFolder));
    struct ServerContext
    {
        HttpAsyncFileServer&                 fileServer;
        HttpAsyncFileServer::StreamQueue<2>* streams;
    } serverCtx          = {fileServer, streams};
    httpServer.onRequest = [this, &serverCtx](HttpConnection& connection)
    {
        SC_TEST_EXPECT(
            serverCtx.fileServer.handleRequest(serverCtx.streams[connection.getConnectionID().getIndex()], connection));
    };

    ClientConnection  clientStorage;
    HttpAsyncClient   client;
    ResponseCollector collector;
    ChunkedBodyStream bodyStream;
    TimeoutGuard      timeout;

    FileSystem fs;
    struct Context
    {
        ResponseCollector& collector;
        HttpAsyncServer&   httpServer;
        FileSystem&        fs;
    } ctx = {collector, httpServer, fs};

    SC_TEST_EXPECT(fs.init(webServerFolder));
    SC_TEST_EXPECT(client.init(clientStorage));
    String url = StringEncoding::Ascii;
    SC_TEST_EXPECT(StringBuilder::format(url, "http://127.0.0.1:{}/client-put-stream.txt", port));
    SC_TEST_EXPECT(bodyStream.init(clientStorage.buffersPool, StringSpan("ChunkedBody").toCharSpan(), 3));

    //! [HttpAsyncClientStreamSnippet]
    client.onPrepareRequest = [this, &bodyStream](HttpAsyncClientRequest& request)
    {
        request.setBody(bodyStream, 11);
        SC_TEST_EXPECT(request.sendHeaders());
    };

    client.onResponse = [this, &ctx](HttpAsyncClientResponse& response)
    {
        ctx.collector.attach(response,
                             [this, &ctx](HttpAsyncClientResponse& completedResponse)
                             {
                                 ctx.collector.detach();
                                 SC_TEST_EXPECT(completedResponse.getParser().statusCode == 201);
                                 String content;
                                 SC_TEST_EXPECT(ctx.fs.read("client-put-stream.txt", content));
                                 SC_TEST_EXPECT(content == "ChunkedBody");
                                 SC_TEST_EXPECT(ctx.fs.removeFile("client-put-stream.txt"));
                                 SC_TEST_EXPECT(ctx.httpServer.stop());
                             });
    };
    client.onError = [this](Result result) { SC_TEST_EXPECT(result); };