From b834f36e2bdb7e5ff93e83ab165ee0310895f6e7 Mon Sep 17 00:00:00 2001
From: crusader <crusader@loafle.com>
Date: Sun, 1 Jul 2018 01:48:16 +0900
Subject: [PATCH] ing

---
 codec/compression_codec.go | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/codec/compression_codec.go b/codec/compression_codec.go
index 0a46339..44dc606 100644
--- a/codec/compression_codec.go
+++ b/codec/compression_codec.go
@@ -48,6 +48,12 @@ func (_ *GZipCodec) Decode(message []byte) ([]byte, error) {
 
 var gZipCodec = &GZipCodec{}
 
+func NewCompressionCodecSelector(threshold int) CodecSelector {
+	return &compressionCodecSelector{
+		threshold: threshold,
+	}
+}
+
 type compressionCodecSelector struct {
 	threshold int
 }