| 117182 | }, |
| 117183 | // parent argument provided by PreFacet subclass |
| 117184 | subflow (key, flow, pulse, parent) { |
| 117185 | const flows = this.value; |
| 117186 | let sf = (0, _vegaUtil.hasOwnProperty)(flows, key) && flows[key], df, p; |
| 117187 | if (!sf) { |
| 117188 | p = parent || (p = this._group[key]) && p.tuple; |
| 117189 | df = pulse.dataflow; |
| 117190 | sf = new Subflow(pulse.fork(pulse.NO_SOURCE), this); |
| 117191 | df.add(sf).connect(flow(df, key, p)); |
| 117192 | flows[key] = sf; |
| 117193 | this.activate(sf); |
| 117194 | } else if (sf.value.stamp < pulse.stamp) { |
| 117195 | sf.init(pulse); |
| 117196 | this.activate(sf); |
| 117197 | } |
| 117198 | return sf; |
| 117199 | }, |
| 117200 | clean () { |
| 117201 | const flows = this.value; |
| 117202 | let detached = 0; |