Method nextImpl

src/Client/ClientBase.cpp:401–414

    }

    void nextImpl() override
    {
        if (on_flush_callback)
            on_flush_callback();

        if (out->isCanceled())
            return;

        out->write(working_buffer.begin(), offset());
        /// Propagate the explicit flush to the nested buffer so that small result blocks
        /// are streamed to the underlying sink immediately instead of waiting for the
        /// nested buffer to fill up.
        out->next();
    }

    void finalizeImpl() override { next(); }