qgrpcstream.h - mozsearch

Enable keyboard shortcuts

// Copyright (C) 2022 The Qt Company Ltd.

// Copyright (C) 2019 Alexey Edelev <semlanik@gmail.com>

// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only

#ifndef QGRPCSTREAM_H

#define QGRPCSTREAM_H

#include <QtGrpc/qgrpcoperation.h>

#include <QtGrpc/qtgrpcglobal.h>

#include <memory>

QT_BEGIN_NAMESPACE

class Q_GRPC_EXPORT QGrpcServerStream final : public QGrpcOperation

    Q_OBJECT

    QT_DEFINE_TAG_STRUCT(PrivateConstructor);

public:

#if QT_GRPC_REMOVED_SINCE(6, 11)

    explicit QGrpcServerStream(std::shared_ptr<QGrpcOperationContext> operationContext,

                               QObject *parent = nullptr);

#endif

    explicit QGrpcServerStream(QLatin1StringView service, QLatin1StringView method,

                               const QGrpcCallOptions &options,

                               std::weak_ptr<QAbstractGrpcChannel> channel,

                               PrivateConstructor);

    ~QGrpcServerStream() override;

Q_SIGNALS:

    void messageReceived();

private:

    Q_DISABLE_COPY_MOVE(QGrpcServerStream)

    friend class QGrpcClientBasePrivate;

public:

    bool event(QEvent *event) override;

};

class Q_GRPC_EXPORT QGrpcClientStream final : public QGrpcOperation

    Q_OBJECT

    QT_DEFINE_TAG_STRUCT(PrivateConstructor);

public:

#if QT_GRPC_REMOVED_SINCE(6, 11)

    explicit QGrpcClientStream(std::shared_ptr<QGrpcOperationContext> operationContext,

                               QObject *parent = nullptr);

#endif

    explicit QGrpcClientStream(QLatin1StringView service, QLatin1StringView method,

                               const QGrpcCallOptions &options,

                               std::weak_ptr<QAbstractGrpcChannel> channel,

                               PrivateConstructor);

    ~QGrpcClientStream() override;

    void writeMessage(const QProtobufMessage &message);

    void writesDone();

    [[nodiscard]] quint64 bytesToWrite() const noexcept;

Q_SIGNALS:

    void messageWritten();

private:

    Q_DISABLE_COPY_MOVE(QGrpcClientStream)

    friend class QGrpcClientBasePrivate;

public:

    bool event(QEvent *event) override;

};

class Q_GRPC_EXPORT QGrpcBidiStream final : public QGrpcOperation

    Q_OBJECT

    QT_DEFINE_TAG_STRUCT(PrivateConstructor);

public:

#if QT_GRPC_REMOVED_SINCE(6, 11)

    explicit QGrpcBidiStream(std::shared_ptr<QGrpcOperationContext> operationContext,

                             QObject *parent = nullptr);

#endif

    explicit QGrpcBidiStream(QLatin1StringView service, QLatin1StringView method,

                             const QGrpcCallOptions &options,

                             std::weak_ptr<QAbstractGrpcChannel> channel,

                             PrivateConstructor);

    ~QGrpcBidiStream() override;

    void writeMessage(const QProtobufMessage &message);

    void writesDone();

    [[nodiscard]] quint64 bytesToWrite() const noexcept;

Q_SIGNALS:

    void messageReceived();

    void messageWritten();

private:

    Q_DISABLE_COPY_MOVE(QGrpcBidiStream)

    friend class QGrpcClientBasePrivate;

public:

    bool event(QEvent *event) override;

};

QT_END_NAMESPACE

#endif // QGRPCSTREAM_H