diff --git a/CHANGELOG.md b/CHANGELOG.md
index 30529e669..5cb8b2053 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,12 @@
 
 
+## [5.10.1](https://github.com/mqttjs/MQTT.js/compare/v5.10.0...v5.10.1) (2024-08-28)
+
+
+### Bug Fixes
+
+* **browser:** handle `Blob` payloads ([#1930](https://github.com/mqttjs/MQTT.js/issues/1930)) ([86b7959](https://github.com/mqttjs/MQTT.js/commit/86b795983d86847e1da334fd0d30cbd80f92b540))
+
 # [5.10.0](https://github.com/mqttjs/MQTT.js/compare/v5.9.1...v5.10.0) (2024-08-14)
 
 
diff --git a/package-lock.json b/package-lock.json
index e1daf8994..3cb01bb3f 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,12 +1,12 @@
 {
   "name": "mqtt",
-  "version": "5.10.0",
+  "version": "5.10.1",
   "lockfileVersion": 2,
   "requires": true,
   "packages": {
     "": {
       "name": "mqtt",
-      "version": "5.10.0",
+      "version": "5.10.1",
       "license": "MIT",
       "dependencies": {
         "@types/readable-stream": "^4.0.5",
diff --git a/package.json b/package.json
index 5d1d9028d..3a397c6df 100644
--- a/package.json
+++ b/package.json
@@ -1,7 +1,7 @@
 {
   "name": "mqtt",
   "description": "A library for the MQTT protocol",
-  "version": "5.10.0",
+  "version": "5.10.1",
   "contributors": [
     "Adam Rudd <adamvrr@gmail.com>",
     "Matteo Collina <matteo.collina@gmail.com> (https://github.com/mcollina)",
diff --git a/src/lib/connect/ws.ts b/src/lib/connect/ws.ts
index 5be4bfce6..5c5b7e978 100644
--- a/src/lib/connect/ws.ts
+++ b/src/lib/connect/ws.ts
@@ -256,9 +256,11 @@ const browserStreamBuilder: StreamBuilder = (client, opts) => {
 	/**
 	 * https://developer.mozilla.org/en-US/docs/Web/API/WebSocket/message_event
 	 */
-	function onMessage(event: MessageEvent) {
+	async function onMessage(event: MessageEvent) {
 		let { data } = event
 		if (data instanceof ArrayBuffer) data = Buffer.from(data)
+		else if (data instanceof Blob)
+			data = Buffer.from(await new Response(data).arrayBuffer())
 		else data = Buffer.from(data as string, 'utf8')
 		if (proxy && !proxy.destroyed) {
 			proxy.push(data)