diff --git a/src/client/compress.js b/src/client/compress.js
new file mode 100644
index 0000000..40d092f
--- /dev/null
+++ b/src/client/compress.js
@@ -0,0 +1,9 @@
+module.exports = function(client) {
+  client.once("compress", onCompressionRequest);
+  client.on("set_compression", onCompressionRequest);
+
+  function onCompressionRequest(packet) {
+    client.compressionThreshold = packet.threshold;
+  }
+  // TODO: refactor with transforms/compression.js -- enable it here
+};
diff --git a/src/createClient.js b/src/createClient.js
index 11f343c..031e2d0 100644
--- a/src/createClient.js
+++ b/src/createClient.js
@@ -9,6 +9,7 @@ var debug = require("./debug");
 var UUID = require('uuid-1345');
 var encrypt = require('./client/encrypt');
 var keepalive = require('./client/keepalive');
+var compress = require('./client/compress');
 
 module.exports=createClient;
 
@@ -49,8 +50,7 @@ function createClient(options) {
   if(keepAlive) keepalive(client);
   encrypt(client);
   client.once('success', onLogin);
-  client.once("compress", onCompressionRequest);
-  client.on("set_compression", onCompressionRequest);
+  compress(client);
   if(haveCredentials) {
     // make a request to get the case-correct username before connecting.
     var cb = function(err, session) {
@@ -101,10 +101,6 @@ function createClient(options) {
     });
   }
 
-  function onCompressionRequest(packet) {
-    client.compressionThreshold = packet.threshold;
-  }
-
   function onLogin(packet) {
     client.state = states.PLAY;
     client.uuid = packet.uuid;