()
| 238 | } |
| 239 | |
| 240 | func (n *NestedContextReader) Row() map[string]value.Value { |
| 241 | current := make(map[string]value.Value) |
| 242 | for _, r := range n.readers { |
| 243 | for k, v := range r.Row() { |
| 244 | // already added this key from a "higher priority" reader |
| 245 | if _, ok := current[k]; ok { |
| 246 | continue |
| 247 | } |
| 248 | |
| 249 | current[k] = v |
| 250 | } |
| 251 | } |
| 252 | |
| 253 | return current |
| 254 | } |
| 255 | |
| 256 | func (n *NestedContextReader) Ts() time.Time { |
| 257 | return n.ts |