()
| 118 | } |
| 119 | |
| 120 | func (w *Writer) Close() error { |
| 121 | // Send the last write (Note: we could reorder things so we do the |
| 122 | // record sort in this thread while waiting for the write to complete.) |
| 123 | if len(w.vals) > 0 { |
| 124 | w.flipBuffers() |
| 125 | } |
| 126 | // Wait for any pending write to finish. |
| 127 | return w.errgroup.Wait() |
| 128 | } |
| 129 | |
| 130 | func (w *Writer) writeObject(object *data.Object, recs []super.Value) error { |
| 131 | var zr sio.Reader |