Block-cache read Pipeline

component/block_cache/block_cache.go

@@ -522,11 +522,15 @@ func (bc *BlockCache) ReadInBuffer(options internal.ReadInBufferOptions) (int, e
 
 		// Copy data from this block to user buffer
 		readOffset := uint64(options.Offset) - block.offset
-		bytesRead := copy(options.Data[dataRead:], block.data[readOffset:])
+		bytesRead := copy(options.Data[dataRead:], block.data[readOffset:(block.endIndex-block.offset)])
 
 		// Move offset forward in case we need to copy more data
 		options.Offset += int64(bytesRead)
 		dataRead += bytesRead
+
+		if (block.endIndex - block.offset) < uint64(len(block.data)) {
+			return 0, io.EOF
+		}
 	}
 
 	return dataRead, nil