(rctx *runtime.Context, outputs map[string]vio.Puller, chans *op.DebugChans)
| 89 | } |
| 90 | |
| 91 | func bundleOutputs(rctx *runtime.Context, outputs map[string]vio.Puller, chans *op.DebugChans) vio.Puller { |
| 92 | switch len(outputs) + len(chans.Debug) { |
| 93 | case 0: |
| 94 | return nil |
| 95 | case 1: |
| 96 | var puller vio.Puller |
| 97 | for k, p := range outputs { |
| 98 | puller = op.NewCatcher(op.NewSingle(k, p)) |
| 99 | } |
| 100 | return puller |
| 101 | default: |
| 102 | return op.NewMux(rctx, outputs, chans) |
| 103 | } |
| 104 | } |
| 105 | |
| 106 | func VectorFilterCompile(rctx *runtime.Context, query string, env *exec.Environment, head *dbid.Commitish) (sbuf.Puller, error) { |
| 107 | // Eventually the semantic analyzer + rungen will resolve the pool but |
no test coverage detected