From 15f63053a806d00d1b7fa37d92ea988093756c37 Mon Sep 17 00:00:00 2001
From: Jehiah Czebotar <jehiah@gmail.com>
Date: Thu, 29 Dec 2016 13:45:24 -0500
Subject: [PATCH] switch to golang/snappy

---
 .travis.yml | 2 +-
 conn.go     | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/.travis.yml b/.travis.yml
index cb55df7a..91d96f22 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -12,7 +12,7 @@ env:
   - NSQ_DOWNLOAD=nsq-0.3.8.linux-amd64.go1.6.2 GOARCH=amd64
   - NSQ_DOWNLOAD=nsq-0.3.8.linux-amd64.go1.6.2 GOARCH=386
 install:
-  - go get github.com/mreiferson/go-snappystream
+  - go get github.com/golang/snappy
 script:
   - wget http://bitly-downloads.s3.amazonaws.com/nsq/$NSQ_DOWNLOAD.tar.gz
   - tar zxvf $NSQ_DOWNLOAD.tar.gz
diff --git a/conn.go b/conn.go
index 2f525b03..4ce9106f 100644
--- a/conn.go
+++ b/conn.go
@@ -15,7 +15,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/mreiferson/go-snappystream"
+	"github.com/golang/snappy"
 )
 
 // IdentifyResponse represents the metadata
@@ -427,8 +427,8 @@ func (c *Conn) upgradeSnappy() error {
 	if c.tlsConn != nil {
 		conn = c.tlsConn
 	}
-	c.r = snappystream.NewReader(conn, snappystream.SkipVerifyChecksum)
-	c.w = snappystream.NewWriter(conn)
+	c.r = snappy.NewReader(conn)
+	c.w = snappy.NewWriter(conn)
 	frameType, data, err := ReadUnpackedResponse(c)
 	if err != nil {
 		return err