()
| 131 | } |
| 132 | |
| 133 | func (m *CsvDataSource) Close() error { |
| 134 | defer func() { |
| 135 | if r := recover(); r != nil { |
| 136 | u.Errorf("close error: %v", r) |
| 137 | } |
| 138 | }() |
| 139 | if m.gz != nil { |
| 140 | m.gz.Close() |
| 141 | } |
| 142 | if m.rc != nil { |
| 143 | m.rc.Close() |
| 144 | } |
| 145 | return nil |
| 146 | } |
| 147 | |
| 148 | func (m *CsvDataSource) Next() schema.Message { |
| 149 | select { |