We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0273ffe commit f1a6a33Copy full SHA for f1a6a33
arrow/ipc/message.go
@@ -150,6 +150,7 @@ type messageReader struct {
150
msg *Message
151
152
mem memory.Allocator
153
+ header [4]byte
154
}
155
156
// NewMessageReader returns a reader that reads messages from an input stream.
@@ -188,7 +189,7 @@ func (r *messageReader) Release() {
188
189
// underlying stream.
190
// It is valid until the next call to Message.
191
func (r *messageReader) Message() (*Message, error) {
- buf := make([]byte, 4)
192
+ buf := r.header[:]
193
_, err := io.ReadFull(r.r, buf)
194
if err != nil {
195
return nil, fmt.Errorf("arrow/ipc: could not read continuation indicator: %w", err)
0 commit comments