| 202 | } |
| 203 | |
| 204 | func (e *jsonInspector) Flush() error { |
| 205 | if len(e.elements) == 0 && len(e.rawElements) == 0 { |
| 206 | _, err := io.WriteString(e.out, "[]\n") |
| 207 | return err |
| 208 | } |
| 209 | |
| 210 | var buffer io.Reader |
| 211 | if len(e.rawElements) > 0 { |
| 212 | bytesBuffer := new(bytes.Buffer) |
| 213 | bytesBuffer.WriteString("[") |
| 214 | for idx, r := range e.rawElements { |
| 215 | bytesBuffer.Write(r) |
| 216 | if idx < len(e.rawElements)-1 { |
| 217 | bytesBuffer.WriteString(",") |
| 218 | } |
| 219 | } |
| 220 | bytesBuffer.WriteString("]") |
| 221 | output := new(bytes.Buffer) |
| 222 | if err := e.raw(output, bytesBuffer.Bytes()); err != nil { |
| 223 | return err |
| 224 | } |
| 225 | buffer = output |
| 226 | } else { |
| 227 | b, err := e.el(e.elements) |
| 228 | if err != nil { |
| 229 | return err |
| 230 | } |
| 231 | buffer = bytes.NewReader(b) |
| 232 | } |
| 233 | |
| 234 | if _, err := io.Copy(e.out, buffer); err != nil { |
| 235 | return err |
| 236 | } |
| 237 | _, err := io.WriteString(e.out, "\n") |
| 238 | return err |
| 239 | } |