Method putStreamBody

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

    SC_TEST_EXPECT(httpServer.close());
    SC_TEST_EXPECT(loop.close());
}

void SC::HttpAsyncClientTest::putStreamBody()
{
    StringView     webServerFolder = report.applicationRootDirectory.view();
    AsyncEventLoop loop;
    SC_TEST_EXPECT(loop.create());

    HttpAsyncFileServer::StreamQueue<2> streams[1];

    ServerConnection    connections[1];
    HttpAsyncServer     httpServer;
    HttpAsyncFileServer fileServer;

    const uint16_t port = report.mapPort(26102);

    ThreadPool threadPool;
    if (loop.needsThreadPoolForFileOperations())
    {
        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)
    {