diff --git a/client_test.go b/client_test.go
index f2407a8a..1bded48c 100644
--- a/client_test.go
+++ b/client_test.go
@@ -140,6 +140,10 @@ func TestTCPClient(t *testing.T) {
 	assert.Equal(t, beforeWriteBytes+20, atomic.LoadUint32(&conn.writeBytes))
 	assert.Nil(t, err)
 	ss.SetCompressType(CompressSnappy)
+	err = ss.WriteBytesArray(pkgs...)
+	assert.Nil(t, err)
+	assert.Equal(t, beforeWritePkgNum+6, atomic.LoadUint32(&conn.writePkgNum))
+	assert.Equal(t, beforeWriteBytes+30, atomic.LoadUint32(&conn.writeBytes))
 	assert.True(t, conn.compress == CompressSnappy)
 
 	clt.Close()
diff --git a/session.go b/session.go
index ad3cd69d..0d2eeffe 100644
--- a/session.go
+++ b/session.go
@@ -452,6 +452,7 @@ func (s *session) WriteBytesArray(pkgs ...[]byte) error {
 		if _, err := s.Connection.send(pkgs); err != nil {
 			return perrors.Wrapf(err, "s.Connection.Write(pkgs num:%d)", len(pkgs))
 		}
+		return nil
 	}
 
 	// get len