* Invoke and await a potentially async callback function. If * an error occurs, trap it and route to Dataflow.error. * @param {Dataflow} df - The dataflow instance * @param {function} callback - A callback function to invoke * and then await. The dataflow will be passed as the single * argu
(df, callback)
| 107191 | * and then await. The dataflow will be passed as the single |
| 107192 | * argument to the function. |
| 107193 | */ async function asyncCallback(df, callback) { |
| 107194 | try { |
| 107195 | await callback(df); |
| 107196 | } catch (err) { |
| 107197 | df.error(err); |
| 107198 | } |
| 107199 | } |
| 107200 | const TUPLE_ID_KEY = Symbol("vega_id"); |
| 107201 | let TUPLE_ID = 1; |
| 107202 | /** |