()
| 10443 | function stream(opts, factory, callback) { |
| 10444 | if (callback === void 0) { |
| 10445 | return new Promise((resolve2, reject) => { |
| 10446 | stream.call(this, opts, factory, (err, data) => { |
| 10447 | return err ? reject(err) : resolve2(data); |
| 10448 | }); |
| 10449 | }); |
| 10450 | } |
| 10451 | try { |
| 10452 | this.dispatch(opts, new StreamHandler(opts, factory, callback)); |
| 10453 | } catch (err) { |
| 10454 | if (typeof callback !== "function") { |