test stream sendMsg

spirt-t · Mar 10, 2021 · fdf81dc · fdf81dc
1 parent d5b6288
commit fdf81dc
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1 @@
+.idea
diff --git a/stream.go b/stream.go
@@ -1581,9 +1581,13 @@ func prepareMsg(m interface{}, codec baseCodec, cp Compressor, comp encoding.Com
 	}
 	// The input interface is not a prepared msg.
 	// Marshal and Compress the data at this point
-	data, err = encode(codec, m)
-	if err != nil {
-		return nil, nil, nil, err
+	var ok bool
+	data, ok = m.([]byte)
+	if !ok {
+		data, err = encode(codec, m)
+		if err != nil {
+			return nil, nil, nil, err
+		}
 	}
 	compData, err := compress(data, cp, comp)
 	if err != nil {