diff --git a/source.js b/source.js
index 887bd6e..695a3a3 100644
--- a/source.js
+++ b/source.js
@@ -21,11 +21,15 @@ module.exports = function(socket, cb) {
   var receiver;
   var ended;
   var started = false;
-  socket.addEventListener('message', function(evt) {
+  socket.addEventListener('message', async function(evt) {
     var data = evt.data;
     if (isArrayBuffer(data)) {
       data = Buffer.from(data);
     }
+    
+    if (typeof Blob !== 'undefined' && data instanceof Blob) {
+      data = Buffer.from(await data.arrayBuffer())
+    }
 
     if (receiver) {
       return receiver(null, data);