* A dataflow graph for reactive processing of data streams. * @constructor
()
| 108705 | * A dataflow graph for reactive processing of data streams. |
| 108706 | * @constructor |
| 108707 | */ function Dataflow() { |
| 108708 | this.logger((0, _vegaUtil.logger)()); |
| 108709 | this.logLevel((0, _vegaUtil.Error)); |
| 108710 | this._clock = 0; |
| 108711 | this._rank = 0; |
| 108712 | this._locale = (0, _vegaFormat.defaultLocale)(); |
| 108713 | try { |
| 108714 | this._loader = (0, _vegaLoader.loader)(); |
| 108715 | } catch (e) {} |
| 108716 | this._touched = UniqueList((0, _vegaUtil.id)); |
| 108717 | this._input = {}; |
| 108718 | this._pulse = null; |
| 108719 | this._heap = Heap((a, b)=>a.qrank - b.qrank); |
| 108720 | this._postrun = []; |
| 108721 | } |
| 108722 | function logMethod(method) { |
| 108723 | return function() { |
| 108724 | return this._log[method].apply(this, arguments); |
nothing calls this directly
no test coverage detected