diff --git a/clamd.go b/clamd.go
index 59e62bf..0e8c18b 100644
--- a/clamd.go
+++ b/clamd.go
@@ -28,6 +28,7 @@ package clamd
 import (
 	"errors"
 	"fmt"
+	"log"
 	"io"
 	"strings"
 )
@@ -243,15 +244,15 @@ func (c *Clamd) ScanStream(r io.Reader) (chan string, error) {
 		buf := make([]byte, CHUNK_SIZE)
 
 		nr, err := r.Read(buf)
+		if nr > 0 {
+		log.Printf("Error %v, %v,  %v", buf[0:nr], nr, err)
+			conn.sendChunk(buf[0:nr])
+		}
+
 		if err != nil {
 			break
 		}
 
-		if nr == 0 {
-			break
-		}
-
-		conn.sendChunk(buf[:nr])
 	}
 
 	err = conn.sendEOF()
diff --git a/conn.go b/conn.go
index 778b92d..b471bb3 100644
--- a/conn.go
+++ b/conn.go
@@ -86,9 +86,7 @@ func (c *CLAMDConn) readResponse() (chan string, sync.WaitGroup, error) {
 
 	// var dataArrays []string
 	go func() {
-		fmt.Println("Start")
 		defer func() {
-			fmt.Println("Cleaning up")
 			close(ch)
 			wg.Done()
 		}()