From 787d92d94ac90a4444a7a7ac9fbffd2ed1e8940e Mon Sep 17 00:00:00 2001
From: Joseph Lawson <joe@joekiller.com>
Date: Sat, 29 Mar 2014 18:23:14 -0400
Subject: [PATCH] attempt to fix test

---
 output_tcp_test.go | 24 ++++++++++++++++--------
 1 file changed, 16 insertions(+), 8 deletions(-)

diff --git a/output_tcp_test.go b/output_tcp_test.go
index c987e3b..05cd738 100644
--- a/output_tcp_test.go
+++ b/output_tcp_test.go
@@ -44,17 +44,25 @@ func startTCP(cb func([]byte)) net.Listener {
 	go func() {
 		for {
 			conn, _ := listener.Accept()
-
+			
 			go func() {
-				scanner := bufio.NewScanner(conn)
-
-				scanner.Split(scanBytes)
-
-				for scanner.Scan() {
-					cb(scanner.Bytes())
-				}
+				reader := bufio.NewReader(conn)
 
+				for {
+					cb(func() {
+						buf,err := reader.ReadBytes('¶')
+						new_buf_len := len(buf) - 2
+						new_buf := make([]byte, new_buf_len)
+						copy(new_buf, buf[:new_buf_len])
+						if err != nil {
+							if err != io.EOF {
+								log.Printf("error: %s\n", err)
+							}
+						}
+						return new_buf
+					}
 				conn.Close()
+			
 			}()
 		}
 	}()