Function parseStream

docs/app/js/sanddance-app.js:146597–146614

* Parse an event stream specification.

(spec)

/**
 * Parse an event stream specification.
 */ function parseStream(spec) {
    var ctx = this, filter = spec.filter != null ? ctx.eventExpression(spec.filter) : undefined, stream = spec.stream != null ? ctx.get(spec.stream) : undefined, args;
    if (spec.source) stream = ctx.events(spec.source, spec.type, filter);
    else if (spec.merge) {
        args = spec.merge.map((_)=>ctx.get(_));
        stream = args[0].merge.apply(args[0], args.slice(1));
    }
    if (spec.between) {
        args = spec.between.map((_)=>ctx.get(_));
        stream = stream.between(args[0], args[1]);
    }
    if (spec.filter) stream = stream.filter(filter);
    if (spec.throttle != null) stream = stream.throttle(+spec.throttle);
    if (spec.debounce != null) stream = stream.debounce(+spec.debounce);
    if (stream == null) (0, _vegaUtil.error)("Invalid stream definition: " + JSON.stringify(spec));
    if (spec.consume) stream.consume(true);
    ctx.stream(spec, stream);
}
/**
 * Parse an event-driven operator update.
 */ function parseUpdate(spec) {