/*
    SPDX-FileCopyrightText: 2023 Aleix Pol Gonzalez <aleixpol@kde.org>

    SPDX-License-Identifier: LGPL-2.1-or-later
*/

#ifndef RESULTSSTREAM_H
#define RESULTSSTREAM_H

#include <QObject>

#include "enginebase.h"
#include "provider.h"

#include "knewstuffcore_export.h"

namespace KNSCore
{
class ResultsStreamPrivate;
/**
 * The ResultsStream is returned by EngineBase::search. It is used to communicate
 * the different entries in response to a request using the signal @m entriesFound.
 *
 * Initially the stream will communicate the entries part of the page as specified
 * in the request. Further pages can be requested using @m fetchMore.
 *
 * Once we have reached the end of the requested stream, the object shall emit
 * @m finished and delete itself.
 *
 * @since 6.0
 */
class KNEWSTUFFCORE_EXPORT ResultsStream : public QObject
{
    Q_OBJECT
public:
    ~ResultsStream() override;

    /// Issues the search, make sure all signals are connected before calling
    void fetch();

    /// Increments the requested page and issues another search
    void fetchMore();

Q_SIGNALS:
    void entriesFound(const KNSCore::Entry::List &entries);
    void finished();

private:
    friend class EngineBase;
    ResultsStream(const Provider::SearchRequest &request, EngineBase *base);
    void finish();

    std::unique_ptr<ResultsStreamPrivate> d;
};

}

#endif // RESULTSSTREAM_H