diff --git a/src/ssn/streams/decryptStream.ts b/src/ssn/streams/decryptStream.ts
index 26ed865..3e9169d 100644
--- a/src/ssn/streams/decryptStream.ts
+++ b/src/ssn/streams/decryptStream.ts
@@ -4,8 +4,13 @@ import getDecryptor from '../decryption/decryptChunk';
 export default function decryptTransform(decryptionKeys: [number, number, number]): stream.Transform {
   const decryptor = getDecryptor(decryptionKeys);
   const transform = new stream.Transform();
+  //TODO: we need to set transform._transform = (chunk) => { return chunk; }
+  transform._transform = (chunk, encoding, callback) => {
+    const decryptedChunk = decryptor(chunk);
+    callback(undefined, decryptedChunk);
+  };
 
-  transform.on('readable', () => {
+  /*transform.on('readable', () => {
     const encryptedChunk = transform.read();
 
     if (encryptedChunk === null) {
@@ -16,7 +21,7 @@ export default function decryptTransform(decryptionKeys: [number, number, number
     const decryptedChunk = decryptor(encryptedChunk);
 
     transform.write(decryptedChunk);
-  });
+  });*/
 
   return transform;
 }