(m *ResultWriter)
| 204 | } |
| 205 | |
| 206 | func resultWrite(m *ResultWriter) MessageHandler { |
| 207 | out := m.MessageOut() |
| 208 | return func(ctx *plan.Context, msg schema.Message) bool { |
| 209 | |
| 210 | // if _, ok := msg.Body().(expr.ContextReader); !ok { |
| 211 | // u.Errorf("could not convert to message reader: %T", msg.Body()) |
| 212 | // } |
| 213 | |
| 214 | select { |
| 215 | case out <- msg: |
| 216 | return true |
| 217 | case <-m.SigChan(): |
| 218 | return false |
| 219 | } |
| 220 | } |
| 221 | } |
| 222 | |
| 223 | func msgToRow(msg schema.Message, cols []string, dest []driver.Value) error { |
| 224 |
no test coverage detected