How to use the @xviz/io.XVIZEnvelope.TransformLogDone function in @xviz/io

To help you get started, we’ve selected a few @xviz/io examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github uber / xviz / modules / server / src / middlewares / xviz-provider-request-handler.js View on Github external
if (iterator.valid() && this.context.transform(id)) {
      loadTimer && loadTimer.timeStart();
      const data = await this.provider.xvizMessage(iterator);
      loadTimer && loadTimer.timeEnd();

      if (data) {
        sendTimer && sendTimer.timeStart();
        this.middleware.onStateUpdate(data);
        sendTimer && sendTimer.timeEnd();

        this.logMsgSent(id, iterator.value(), loadTimer, sendTimer);
      }

      transformState.interval = setTimeout(() => this._sendStateUpdate(id, transformState), delay);
    } else {
      this.middleware.onTransformLogDone(XVIZEnvelope.TransformLogDone({id}));
      totalTimer && totalTimer.timeEnd();
      this.logDone(id, loadTimer, sendTimer, totalTimer);
      this.context.endTransform(id);
      this.metrics.reset();
    }
  }
  /* eslint-enable complexity */
github uber / xviz / modules / server / src / middlewares / xviz-provider-request-handler.js View on Github external
// End when finished iteration or transform has been removed.
    while (iterator.valid() && this.context.transform(id)) {
      loadTimer && loadTimer.timeStart();
      const data = await this.provider.xvizMessage(iterator);
      loadTimer && loadTimer.timeEnd();

      if (data) {
        sendTimer && sendTimer.timeStart();
        this.middleware.onStateUpdate(data);
        sendTimer && sendTimer.timeEnd();

        this.logMsgSent(id, iterator.value(), loadTimer, sendTimer);
      }
    }

    this.middleware.onTransformLogDone(XVIZEnvelope.TransformLogDone({id}));
    totalTimer && totalTimer.timeEnd();
    this.logDone(id, loadTimer, sendTimer, totalTimer);
    this.context.endTransform(id);
    this.metrics.reset();
  }