func()

in internal/mode/chunk/streamer/streamer.go [122:134]

• 9 lines of code
• 2 McCabe index (conditional complexity)

func (s *Streamer) Close() error {
	s.mu.Lock()
	defer s.mu.Unlock()

	// Flush the writer directly, not via the method since we already hold the lock
	s.csvWriter.Flush()

	if closer, ok := s.writer.(io.Closer); ok {
		return closer.Close()
	}

	return nil
}