diff --git a/Streamer.js b/Streamer.js
index 10a13ea..4938503 100644
--- a/Streamer.js
+++ b/Streamer.js
@@ -24,10 +24,13 @@ class Streamer {
         console.log(write_stream)
         console.log('writing buffer', buffer.toString(), buffer)
 
-        const read_stream = new Readable()
-        read_stream.push(buffer.toString())
-        read_stream.push(null)
-        read_stream.pipe(write_stream)
+        write_stream.push(buffer)
+        write_stream.push(null)
+
+        // const read_stream = new Readable()
+        // read_stream.push(buffer, 'utf8')
+        // read_stream.push(null)
+        // read_stream.pipe(write_stream)
     }
 
     stream() {