Add buffers to stream channel. Check data packet type in iterator (#30)

datastreamer/streamfile.go

@@ -694,12 +694,12 @@ func (f *StreamFile) iteratorNext(iterator *iteratorFile) (bool, error) {
 			log.Errorf("Error reading new packet type for iterator: %v", err)
 			return true, err
 		}
+	}
 
-		// Should be of type data
-		if packet[0] != PtData {
-			log.Errorf("Error data page not starting with packet of type data. Type: %d", packet[0])
-			return true, errors.New("page not starting with entry data")
-		}
+	// Should be of type data
+	if packet[0] != PtData {
+		log.Errorf("Error expecting packet of type data(%d). Read: %d", PtData, packet[0])
+		return true, errors.New("error expecting packet type data")
 	}
 
 	// Read the rest of fixed data entry bytes

datastreamer/streamserver.go

@@ -21,6 +21,8 @@ type StreamType uint64
 type CommandError uint32
 
 const (
+	streamBuffer = 128 // Buffers for the stream channel
+
 	// Commands
 	CmdUnknown Command = 0
 	CmdStart   Command = 1
@@ -121,7 +123,7 @@ func New(port uint16, streamType StreamType, fileName string) (StreamServer, err
 			startEntry: 0,
 			entries:    []FileEntry{},
 		},
-		stream: make(chan streamAO),
+		stream: make(chan streamAO, streamBuffer),
 	}
 
 	// Open (or create) the data stream file