1 files changed, 4 insertions, 2 deletions
diff --git a/linkmsg.go b/linkmsg.go
index 97ed141..0c384a3 100644
--- a/linkmsg.go
+++ b/linkmsg.go
@@ -4,6 +4,7 @@ import (
 	"bufio"
 	"encoding/json"
 	"errors"
+	"io"
 	. "strconv"
 )
 
@@ -143,8 +144,9 @@ func linkMsgRead(rd *bufio.Reader) (msg interface{}, err error) {
 	return
 }
 
-func linkMsgFmt(msg interface{}, buf []byte) []byte {
+func linkMsgWrite(wr io.Writer, msg interface{}) (int, error) {
 	// Somewhat low-level, but oh well
+	var buf []byte
 	switch m := msg.(type) {
 	case linkMsgPatternsync:
 		if m {
@@ -184,5 +186,5 @@ func linkMsgFmt(msg interface{}, buf []byte) []byte {
 		buf = append(buf, []byte(FormatInt(int64(m), 10))...)
 		buf = append(buf, []byte("]\n")...)
 	}
-	return buf
+	return wr.Write(buf)
 }