(header []byte)
| 165 | } |
| 166 | |
| 167 | func (f *fullReader) ReadMessageHeader(header []byte) error { |
| 168 | buf, err := f.Read(len(header)) |
| 169 | defer buf.Free() |
| 170 | if err != nil { |
| 171 | return err |
| 172 | } |
| 173 | |
| 174 | buf.CopyTo(header) |
| 175 | return nil |
| 176 | } |
| 177 | |
| 178 | func (f *fullReader) Read(n int) (mem.BufferSlice, error) { |
| 179 | if n == 0 { |