emit TestWebSocket signals

fastly · Dec 11, 2023 · a18df3d · a18df3d
1 parent 0c77eed
commit a18df3d
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 3 deletions.
diff --git a/src/cpp/proxy/testwebsocket.cpp b/src/cpp/proxy/testwebsocket.cpp
@@ -285,6 +285,18 @@ WebSocket::ErrorCondition TestWebSocket::errorCondition() const
 	return d->errorCondition;
 }
 
+void TestWebSocket::emit_readyRead(){
+	this->readyRead();
+}
+
+void TestWebSocket::emit_framesWritten(int count, int contentBytes){
+	this->framesWritten(count, contentBytes);
+}
+
+void TestWebSocket::emit_writeBytesChanged(){
+	this->writeBytesChanged();
+}
+
 void TestWebSocket::writeFrame(const Frame &frame)
 {
 	Frame tmp = frame;
@@ -296,13 +308,13 @@ void TestWebSocket::writeFrame(const Frame &frame)
 
 	d->inFrames += tmp;
 
-	this->framesWritten(1, tmp.data.size());
-	this->readyRead();
+	QMetaObject::invokeMethod(this, "emit_framesWritten", Qt::QueuedConnection, Q_ARG(int, 1), Q_ARG(int, tmp.data.size()));
+	QMetaObject::invokeMethod(this, "emit_readyRead", Qt::QueuedConnection);
 }
 
 WebSocket::Frame TestWebSocket::readFrame()
 {
-	this->writeBytesChanged();
+	QMetaObject::invokeMethod(this, "emit_writeBytesChanged", Qt::QueuedConnection);
 
 	return d->inFrames.takeFirst();
 }

diff --git a/src/cpp/proxy/testwebsocket.h b/src/cpp/proxy/testwebsocket.h
@@ -64,6 +64,9 @@ class TestWebSocket : public WebSocket
 	virtual QString peerCloseReason() const;
 	virtual ErrorCondition errorCondition() const;
 
+	virtual void emit_readyRead();
+	virtual void emit_framesWritten(int count, int contentBytes);
+	virtual void emit_writeBytesChanged();
 	virtual void writeFrame(const Frame &frame);
 	virtual Frame readFrame();
 	virtual void close(int code = -1, const QString &reason = QString());