Method sendData

src/Client/Connection.cpp:1089–1118

void Connection::sendData(const Block & block, const String & name, bool scalar)
{
    if (!block_out)
    {
        if (compression == Protocol::Compression::Enable)
            maybe_compressed_out = std::make_unique<CompressedWriteBuffer>(*out, compression_codec);
        else
            maybe_compressed_out = out;

        block_out = std::make_unique<NativeWriter>(*maybe_compressed_out, server_revision, std::make_shared<const Block>(block.cloneEmpty()), format_settings);
    }

    if (scalar)
        writeVarUInt(Protocol::Client::Scalar, *out);
    else
        writeVarUInt(Protocol::Client::Data, *out);
    writeStringBinary(name, *out);

    size_t prev_bytes = out->count();

    block_out->write(block);
    if (maybe_compressed_out != out)
        maybe_compressed_out->next();
    if (block.empty())
        out->finishChunk();
    out->next();

    if (throttler)
        throttler->throttle(out->count() - prev_bytes);
}

void Connection::sendClusterFunctionReadTaskResponse(const ClusterFunctionReadTaskResponse & response)
{