()
| 124 | } |
| 125 | |
| 126 | func (m *JsonSource) Close() error { |
| 127 | defer func() { |
| 128 | if r := recover(); r != nil { |
| 129 | u.Errorf("close error: %v", r) |
| 130 | } |
| 131 | }() |
| 132 | if m.gz != nil { |
| 133 | m.gz.Close() |
| 134 | } |
| 135 | if m.rc != nil { |
| 136 | m.rc.Close() |
| 137 | } |
| 138 | return nil |
| 139 | } |
| 140 | |
| 141 | func (m *JsonSource) Next() schema.Message { |
| 142 | select { |