qiurui
/
qtgrpc
mirror of https://github.com/qt/qtgrpc.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chat example: fix sendMessage() new unique_ptr workflow 

This was forgotten when we switched to unique_ptr's.

Pick-to: 6.8.0 6.8
Change-Id: I684639bbafc65ea5eea34074a77367b82c9d9054
Reviewed-by:  Alexey Edelev <alexey.edelev@qt.io>
This commit is contained in:
Dennis Oberst 2024-09-12 14:54:42 +02:00
parent fe03f6972c
commit 2b1c2ec411
1 changed files with 26 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
examples/grpc/chat/client/simplechatengine.cpp
View File

@ -20,6 +20,8 @@
#include <QByteArray>
#include <QBuffer>
#include <memory>
SimpleChatEngine::SimpleChatEngine(QObject *parent)
: QObject(parent),
m_state(Disconnected),
@ -103,7 +105,20 @@ void SimpleChatEngine::sendMessage(const QString &content)
msg.setType(qtgrpc::examples::chat::ChatMessage::ContentType::Text);
msg.setTimestamp(QDateTime::currentMSecsSinceEpoch());
msg.setFrom(m_userName);
m_client->sendMessage(msg);
std::unique_ptr<QGrpcCallReply> reply = m_client->sendMessage(msg);
// We explicitly take a copy of the reply pointer, since moving it into
// the lambda would make the get() function invalid.
// Reply's lifetime will be extended until finished() is emitted.
// Qt::SingleShotConnection is needed to destroy the lambda (and its capture).
auto *replyPtr = reply.get();
connect(
replyPtr, &QGrpcCallReply::finished, this,
[reply = std::move(reply)](const QGrpcStatus &status) {
if (!status.isOk())
qDebug() << "Failed to send message: " << status;
},
Qt::SingleShotConnection);
// ![2]
}
@ -163,7 +178,16 @@ void SimpleChatEngine::sendImageFromClipboard()
msg.setType(qtgrpc::examples::chat::ChatMessage::ContentType::Image);
msg.setTimestamp(QDateTime::currentMSecsSinceEpoch());
msg.setFrom(m_userName);
m_client->sendMessage(msg);
std::unique_ptr<QGrpcCallReply> reply = m_client->sendMessage(msg);
auto *replyPtr = reply.get();
connect(
replyPtr, &QGrpcCallReply::finished, this,
[reply = std::move(reply)](const QGrpcStatus &status) {
if (!status.isOk())
qDebug() << "Failed to send clipboard message: " << status;
},
Qt::SingleShotConnection);
}
ChatMessageModel *SimpleChatEngine::messages()