diff --git a/src/websockets/qwebsocket.cpp b/src/websockets/qwebsocket.cpp
index 1b0fc351b7583735b182a972d18202794ae74d0f..64d5e4c7ef78108eca57dea52f725780311a6a17 100644
--- a/src/websockets/qwebsocket.cpp
+++ b/src/websockets/qwebsocket.cpp
@@ -772,4 +772,17 @@ bool QWebSocket::isValid() const
     return d->isValid();
 }
 
+/*!
+    \since 5.12
+    Returns the number of bytes that are waiting to be written. The bytes are written when control
+    goes back to the event loop or when flush() is called.
+
+    \sa flush
+ */
+qint64 QWebSocket::bytesToWrite() const
+{
+    Q_D(const QWebSocket);
+    return d->m_pSocket ? d->m_pSocket->bytesToWrite() : 0;
+}
+
 QT_END_NAMESPACE
diff --git a/src/websockets/qwebsocket.h b/src/websockets/qwebsocket.h
index a80c47a31dd4a38f745df7defb4a4750ed44f701..b8742e81c66208a418e963743db5cc847b9bfdcb 100644
--- a/src/websockets/qwebsocket.h
+++ b/src/websockets/qwebsocket.h
@@ -113,6 +113,8 @@ public:
     QSslConfiguration sslConfiguration() const;
 #endif
 
+    qint64 bytesToWrite() const;
+
 public Q_SLOTS:
     void close(QWebSocketProtocol::CloseCode closeCode = QWebSocketProtocol::CloseCodeNormal,
                const QString &reason = QString());
diff --git a/tests/auto/websockets/qwebsocket/tst_qwebsocket.cpp b/tests/auto/websockets/qwebsocket/tst_qwebsocket.cpp
index ac54270469ccc9bb2b8b1e6843898e3d129c7709..e80eeb100114667c7522c54853f0b0ed3a26280b 100644
--- a/tests/auto/websockets/qwebsocket/tst_qwebsocket.cpp
+++ b/tests/auto/websockets/qwebsocket/tst_qwebsocket.cpp
@@ -434,9 +434,13 @@ void tst_QWebSocket::tst_sendTextMessage()
     QUrl urlConnected = arguments.at(0).toUrl();
     QCOMPARE(urlConnected, url);
 
+    QCOMPARE(socket.bytesToWrite(), 0);
     socket.sendTextMessage(QStringLiteral("Hello world!"));
+    QVERIFY(socket.bytesToWrite() > 12); // 12 + a few extra bytes for header
 
     QVERIFY(textMessageReceived.wait(500));
+    QCOMPARE(socket.bytesToWrite(), 0);
+
     QCOMPARE(textMessageReceived.count(), 1);
     QCOMPARE(binaryMessageReceived.count(), 0);
     QCOMPARE(binaryFrameReceived.count(), 0);
@@ -508,9 +512,13 @@ void tst_QWebSocket::tst_sendBinaryMessage()
     QTRY_COMPARE(socketConnectedSpy.count(), 1);
     QCOMPARE(socket.state(), QAbstractSocket::ConnectedState);
 
+    QCOMPARE(socket.bytesToWrite(), 0);
     socket.sendBinaryMessage(QByteArrayLiteral("Hello world!"));
+    QVERIFY(socket.bytesToWrite() > 12); // 12 + a few extra bytes for header
 
     QVERIFY(binaryMessageReceived.wait(500));
+    QCOMPARE(socket.bytesToWrite(), 0);
+
     QCOMPARE(textMessageReceived.count(), 0);
     QCOMPARE(textFrameReceived.count(), 0);
     QCOMPARE(binaryMessageReceived.count(), 1);
diff --git a/tests/auto/websockets/qwebsocketserver/tst_qwebsocketserver.cpp b/tests/auto/websockets/qwebsocketserver/tst_qwebsocketserver.cpp
index 8a3760d851b7c1da039b145e5ea661443f84e826..a2f3c150ade6a000469c77df8bcd551ab433fa5c 100644
--- a/tests/auto/websockets/qwebsocketserver/tst_qwebsocketserver.cpp
+++ b/tests/auto/websockets/qwebsocketserver/tst_qwebsocketserver.cpp
@@ -640,6 +640,14 @@ void tst_QWebSocketServer::tst_handleConnection()
     QTRY_COMPARE(wsMessageReceivedSpy.count(), 1);
     QList<QVariant> arguments = wsMessageReceivedSpy.takeFirst();
     QCOMPARE(arguments.first().toString(), QString("dummy"));
+
+    QSignalSpy clientMessageReceivedSpy(&webSocket, &QWebSocket::textMessageReceived);
+    webServerSocket->sendTextMessage("hello");
+    QVERIFY(webServerSocket->bytesToWrite() > 5); // 5 + a few extra bytes for header
+    QTRY_COMPARE(webServerSocket->bytesToWrite(), 0);
+    QTRY_COMPARE(clientMessageReceivedSpy.count(), 1);
+    arguments = clientMessageReceivedSpy.takeFirst();
+    QCOMPARE(arguments.first().toString(), QString("hello"));
 }
 
 QTEST_MAIN(tst_QWebSocketServer)