diff options
Diffstat (limited to 'stream_handler.go')
| -rw-r--r-- | stream_handler.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/stream_handler.go b/stream_handler.go index 8042bcb..01c0b08 100644 --- a/stream_handler.go +++ b/stream_handler.go @@ -61,7 +61,7 @@ func NewStreamHandler(connection ConnectionHandler, streamFlow StreamFlow, scann indexes: make([]int, 0, InitialBlockCount), timestamps: make([]time.Time, 0, InitialBlockCount), lossBlocks: make([]bool, 0, InitialBlockCount), - documentsIDs: make([]RowID, 0, 1), // most of the time the stream fit in one document + documentsIDs: make([]RowID, 0, 1), // most of the time the stream fit in one document patternMatches: make(map[uint][]PatternSlice, connection.PatternsDatabaseSize()), scanner: scanner, isClient: isClient, @@ -179,7 +179,7 @@ func (sh *StreamHandler) storageCurrentDocument() { ConnectionID: ZeroRowID, DocumentIndex: len(sh.documentsIDs), Payload: sh.buffer.Bytes(), - PayloadString: strings.ToValidUTF8(string(sh.buffer.Bytes()), ""), + PayloadString: strings.ToValidUTF8(string(sh.buffer.Bytes()), ""), BlocksIndexes: sh.indexes, BlocksTimestamps: sh.timestamps, BlocksLoss: sh.lossBlocks, |